public class AggregationCombineFnAdapter<T>
extends java.lang.Object
Combine.CombineFn
s for aggregation function calls.Modifier and Type | Field and Description |
---|---|
static Row |
EMPTY_ROW |
static Schema |
EMPTY_SCHEMA |
Constructor and Description |
---|
AggregationCombineFnAdapter() |
Modifier and Type | Method and Description |
---|---|
static Combine.CombineFn<?,?,?> |
createCombineFn(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.core.AggregateCall call,
Schema.Field field,
java.lang.String functionName)
Creates either a UDAF or a built-in
Combine.CombineFn . |
static Combine.CombineFn<Row,?,Row> |
createConstantCombineFn() |
public static final Schema EMPTY_SCHEMA
public static final Row EMPTY_ROW
public static Combine.CombineFn<?,?,?> createCombineFn(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.core.AggregateCall call, Schema.Field field, java.lang.String functionName)
Combine.CombineFn
.public static Combine.CombineFn<Row,?,Row> createConstantCombineFn()