| 317 | using OutputType = typename TypeTraits<AccType>::ScalarType; |
| 318 | |
| 319 | explicit ProductImpl(std::shared_ptr<DataType> out_type, |
| 320 | const ScalarAggregateOptions& options) |
| 321 | : out_type(out_type), |
| 322 | options(options), |
| 323 | count(0), |
| 324 | product(MultiplyTraits<AccType>::one(*out_type)), |
| 325 | nulls_observed(false) {} |
| 326 | |
| 327 | Status Consume(KernelContext*, const ExecSpan& batch) override { |
| 328 | if (batch[0].is_array()) { |