public class BeamBuiltinAggregations
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.util.Map<java.lang.String,java.util.function.Function<Schema.FieldType,Combine.CombineFn<?,?,?>>> |
BUILTIN_AGGREGATOR_FACTORIES |
Constructor and Description |
---|
BeamBuiltinAggregations() |
Modifier and Type | Method and Description |
---|---|
static Combine.CombineFn<?,?,?> |
create(java.lang.String functionName,
Schema.FieldType fieldType) |
public static final java.util.Map<java.lang.String,java.util.function.Function<Schema.FieldType,Combine.CombineFn<?,?,?>>> BUILTIN_AGGREGATOR_FACTORIES
public static Combine.CombineFn<?,?,?> create(java.lang.String functionName, Schema.FieldType fieldType)