Module datafusion_physical_expr_common::aggregate::utils

Structs

• DecimalAverager
  Computes averages for Decimal128/Decimal256 values, checking for overflow
• Hashable
  A wrapper around a type to provide hash for floats

Functions

• adjust_output_array
  Adjust array type metadata if needed
• down_cast_any_ref
  Downcast a Box<dyn AggregateExpr> or Arc<dyn AggregateExpr> and return the inner trait object as Any so that it can be downcast to a specific implementation.
• get_accum_scalar_values_as_arrays
  Convert scalar values from an accumulator into arrays.
• get_sort_options
  Selects the sort option attribute from all the given PhysicalSortExprs.
• ordering_fields
  Construct corresponding fields for lexicographical ordering requirement expression