Skip to content

AggregatePushDownUtils

getSchemaForPushedAggregation

getSchemaForPushedAggregation(
  aggregation: Aggregation,
  schema: StructType,
  partitionNames: Set[String],
  dataFilters: Seq[Expression]): Option[StructType]

getSchemaForPushedAggregation...FIXME


getSchemaForPushedAggregation is used when:

  • OrcScanBuilder is requested to pushAggregation
  • ParquetScanBuilder is requested to pushAggregation