Package org.apache.beam.sdk.extensions.sql.impl.transform.agg

Class AggregationCombineFnAdapter<T>

  • public class AggregationCombineFnAdapter<T>
extends java.lang.Object
    Wrapper Combine.CombineFns for aggregation function calls.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static org.apache.beam.sdk.values.Row EMPTY_ROW  
      static org.apache.beam.sdk.schemas.Schema EMPTY_SCHEMA  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static org.apache.beam.sdk.transforms.Combine.CombineFn<?,​?,​?> createCombineFn​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.core.AggregateCall call, org.apache.beam.sdk.schemas.Schema.Field field, java.lang.String functionName)
      Creates either a UDAF or a built-in Combine.CombineFn.
      static org.apache.beam.sdk.transforms.Combine.CombineFn<?,​?,​?> createCombineFnAnalyticsFunctions​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.core.AggregateCall call, org.apache.beam.sdk.schemas.Schema.Field field, java.lang.String functionName)
      Creates either a UDAF or a built-in Combine.CombineFn for Analytic Functions.
      static org.apache.beam.sdk.transforms.Combine.CombineFn<org.apache.beam.sdk.values.Row,​?,​org.apache.beam.sdk.values.Row> createConstantCombineFn()  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • EMPTY_SCHEMA

        public static final org.apache.beam.sdk.schemas.Schema EMPTY_SCHEMA

      • EMPTY_ROW

        public static final org.apache.beam.sdk.values.Row EMPTY_ROW

    • Constructor Detail

      • AggregationCombineFnAdapter

        public AggregationCombineFnAdapter()

    • Method Detail

      • createCombineFn

        public static org.apache.beam.sdk.transforms.Combine.CombineFn<?,​?,​?> createCombineFn​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.core.AggregateCall call,
                                                                                                  org.apache.beam.sdk.schemas.Schema.Field field,
                                                                                                  java.lang.String functionName)
        Creates either a UDAF or a built-in Combine.CombineFn.

      • createCombineFnAnalyticsFunctions

        public static org.apache.beam.sdk.transforms.Combine.CombineFn<?,​?,​?> createCombineFnAnalyticsFunctions​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rel.core.AggregateCall call,
                                                                                                                    org.apache.beam.sdk.schemas.Schema.Field field,
                                                                                                                    java.lang.String functionName)
        Creates either a UDAF or a built-in Combine.CombineFn for Analytic Functions.

      • createConstantCombineFn

        public static org.apache.beam.sdk.transforms.Combine.CombineFn<org.apache.beam.sdk.values.Row,​?,​org.apache.beam.sdk.values.Row> createConstantCombineFn()