Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
TableEnvironment.registerAggregateFunctionInternal(String name,
AggregateFunction<T,ACC> function,
TypeInformation<T> evidence$2)
Registers an
AggregateFunction under a unique name. |
Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
BatchTableEnvironment.registerFunction(String name,
AggregateFunction<T,ACC> f)
Registers an
AggregateFunction under a unique name in the TableEnvironment's catalog. |
<T,ACC> void |
StreamTableEnvironment.registerFunction(String name,
AggregateFunction<T,ACC> f)
Registers an
AggregateFunction under a unique name in the TableEnvironment's catalog. |
Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
BatchTableEnvironment.registerFunction(String name,
AggregateFunction<T,ACC> f,
TypeInformation<T> evidence$3)
Registers an
AggregateFunction under a unique name in the TableEnvironment's catalog. |
<T,ACC> void |
StreamTableEnvironment.registerFunction(String name,
AggregateFunction<T,ACC> f,
TypeInformation<T> evidence$8)
Registers an
AggregateFunction under a unique name in the TableEnvironment's catalog. |
<T,ACC> UDAGGExpression<T,ACC> |
ImplicitExpressionConversions.userDefinedAggFunctionConstructor(AggregateFunction<T,ACC> udagg,
TypeInformation<T> evidence$1) |
Modifier and Type | Method and Description |
---|---|
GeneratedAggregationsFunction |
CodeGenerator.generateAggregations(String name,
CodeGenerator generator,
scala.collection.Seq<TypeInformation<?>> physicalInputTypes,
AggregateFunction<?,?>[] aggregates,
int[][] aggFields,
int[] aggMapping,
boolean partialResults,
int[] fwdMapping,
scala.Option<int[]> mergeMapping,
scala.Option<scala.Tuple2<Object,Object>[]> constantFlags,
int outputArity,
boolean needRetract,
boolean needMerge,
boolean needReset)
Generates a
GeneratedAggregations that can be
passed to a Java compiler. |
Modifier and Type | Method and Description |
---|---|
AggregateFunction<T,ACC> |
UDAGGExpression.aggregateFunction() |
Constructor and Description |
---|
AggFunctionCall(AggregateFunction<?,?> aggregateFunction,
scala.collection.Seq<Expression> args) |
UDAGGExpression(AggregateFunction<T,ACC> aggregateFunction,
TypeInformation<T> evidence$1) |
Modifier and Type | Class and Description |
---|---|
class |
BigIntegralAvgAggFunction<T>
Base Class for Built-in Big Integral Avg aggregate function
|
class |
BooleanMaxAggFunction
Built-in Boolean Max aggregate function
|
class |
BooleanMaxWithRetractAggFunction
Built-in Boolean Max with retraction aggregate function
|
class |
BooleanMinAggFunction
Built-in Boolean Min aggregate function
|
class |
BooleanMinWithRetractAggFunction
Built-in Boolean Min with retraction aggregate function
|
class |
ByteAvgAggFunction
Built-in Byte Avg aggregate function
|
class |
ByteMaxAggFunction
Built-in Byte Max aggregate function
|
class |
ByteMaxWithRetractAggFunction
Built-in Byte Max with retraction aggregate function
|
class |
ByteMinAggFunction
Built-in Byte Min aggregate function
|
class |
ByteMinWithRetractAggFunction
Built-in Byte Min with retraction aggregate function
|
class |
ByteSum0AggFunction
Built-in Byte Sum0 aggregate function
|
class |
ByteSum0WithRetractAggFunction
Built-in Byte Sum0 with retract aggregate function
|
class |
ByteSumAggFunction
Built-in Byte Sum aggregate function
|
class |
ByteSumWithRetractAggFunction
Built-in Byte Sum with retract aggregate function
|
class |
CountAggFunction
built-in count aggregate function
|
class |
DecimalAvgAggFunction
Base class for built-in Big Decimal Avg aggregate function
|
class |
DecimalMaxAggFunction
Built-in Big Decimal Max aggregate function
|
class |
DecimalMaxWithRetractAggFunction
Built-in Big Decimal Max with retraction aggregate function
|
class |
DecimalMinAggFunction
Built-in Big Decimal Min aggregate function
|
class |
DecimalMinWithRetractAggFunction
Built-in Big Decimal Min with retraction aggregate function
|
class |
DecimalSum0AggFunction
Built-in Big Decimal Sum0 aggregate function
|
class |
DecimalSum0WithRetractAggFunction
Built-in Big Decimal Sum0 with retract aggregate function
|
class |
DecimalSumAggFunction
Built-in Big Decimal Sum aggregate function
|
class |
DecimalSumWithRetractAggFunction
Built-in Big Decimal Sum with retract aggregate function
|
class |
DoubleAvgAggFunction
Built-in Int Double aggregate function
|
class |
DoubleMaxAggFunction
Built-in Double Max aggregate function
|
class |
DoubleMaxWithRetractAggFunction
Built-in Double Max with retraction aggregate function
|
class |
DoubleMinAggFunction
Built-in Double Min aggregate function
|
class |
DoubleMinWithRetractAggFunction
Built-in Double Min with retraction aggregate function
|
class |
DoubleSum0AggFunction
Built-in Double Sum0 aggregate function
|
class |
DoubleSum0WithRetractAggFunction
Built-in Double Sum0 with retract aggregate function
|
class |
DoubleSumAggFunction
Built-in Double Sum aggregate function
|
class |
DoubleSumWithRetractAggFunction
Built-in Double Sum with retract aggregate function
|
class |
FloatAvgAggFunction
Built-in Float Avg aggregate function
|
class |
FloatingAvgAggFunction<T>
Base class for built-in Floating Avg aggregate function
|
class |
FloatMaxAggFunction
Built-in Float Max aggregate function
|
class |
FloatMaxWithRetractAggFunction
Built-in Float Max with retraction aggregate function
|
class |
FloatMinAggFunction
Built-in Float Min aggregate function
|
class |
FloatMinWithRetractAggFunction
Built-in Float Min with retraction aggregate function
|
class |
FloatSum0AggFunction
Built-in Float Sum0 aggregate function
|
class |
FloatSum0WithRetractAggFunction
Built-in Float Sum0 with retract aggregate function
|
class |
FloatSumAggFunction
Built-in Float Sum aggregate function
|
class |
FloatSumWithRetractAggFunction
Built-in Float Sum with retract aggregate function
|
class |
IntAvgAggFunction
Built-in Int Avg aggregate function
|
class |
IntegralAvgAggFunction<T>
Base class for built-in Integral Avg aggregate function
|
class |
IntMaxAggFunction
Built-in Int Max aggregate function
|
class |
IntMaxWithRetractAggFunction
Built-in Int Max with retraction aggregate function
|
class |
IntMinAggFunction
Built-in Int Min aggregate function
|
class |
IntMinWithRetractAggFunction
Built-in Int Min with retraction aggregate function
|
class |
IntSum0AggFunction
Built-in Int Sum0 aggregate function
|
class |
IntSum0WithRetractAggFunction
Built-in Int Sum0 with retract aggregate function
|
class |
IntSumAggFunction
Built-in Int Sum aggregate function
|
class |
IntSumWithRetractAggFunction
Built-in Int Sum with retract aggregate function
|
class |
LongAvgAggFunction
Built-in Long Avg aggregate function
|
class |
LongMaxAggFunction
Built-in Long Max aggregate function
|
class |
LongMaxWithRetractAggFunction
Built-in Long Max with retraction aggregate function
|
class |
LongMinAggFunction
Built-in Long Min aggregate function
|
class |
LongMinWithRetractAggFunction
Built-in Long Min with retraction aggregate function
|
class |
LongSum0AggFunction
Built-in Long Sum0 aggregate function
|
class |
LongSum0WithRetractAggFunction
Built-in Long Sum0 with retract aggregate function
|
class |
LongSumAggFunction
Built-in Long Sum aggregate function
|
class |
LongSumWithRetractAggFunction
Built-in Long Sum with retract aggregate function
|
class |
MaxAggFunction<T>
Base class for built-in Max aggregate function
|
class |
MaxWithRetractAggFunction<T>
Base class for built-in Max with retraction aggregate function
|
class |
MinAggFunction<T>
Base class for built-in Min aggregate function
|
class |
MinWithRetractAggFunction<T>
Base class for built-in Min with retraction aggregate function
|
class |
ShortAvgAggFunction
Built-in Short Avg aggregate function
|
class |
ShortMaxAggFunction
Built-in Short Max aggregate function
|
class |
ShortMaxWithRetractAggFunction
Built-in Short Max with retraction aggregate function
|
class |
ShortMinAggFunction
Built-in Short Min aggregate function
|
class |
ShortMinWithRetractAggFunction
Built-in Short Min with retraction aggregate function
|
class |
ShortSum0AggFunction
Built-in Short Sum0 aggregate function
|
class |
ShortSum0WithRetractAggFunction
Built-in Short Sum0 with retract aggregate function
|
class |
ShortSumAggFunction
Built-in Short Sum aggregate function
|
class |
ShortSumWithRetractAggFunction
Built-in Short Sum with retract aggregate function
|
class |
StringMaxAggFunction
Built-in String Max aggregate function
|
class |
StringMaxWithRetractAggFunction
Built-in String Max with retraction aggregate function
|
class |
StringMinAggFunction
Built-in String Min aggregate function
|
class |
StringMinWithRetractAggFunction
Built-in String Min with retraction aggregate function
|
class |
Sum0AggFunction<T>
Base class for built-in Sum0 aggregate function.
|
class |
Sum0WithRetractAggFunction<T>
Base class for built-in Sum0 with retract aggregate function.
|
class |
SumAggFunction<T>
Base class for built-in Sum aggregate function
|
class |
SumWithRetractAggFunction<T>
Base class for built-in Sum with retract aggregate function
|
Modifier and Type | Method and Description |
---|---|
AggregateFunction<?,?> |
AggSqlFunction.getFunction() |
Modifier and Type | Method and Description |
---|---|
AggSqlFunction |
AggSqlFunction$.apply(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> returnType,
FlinkTypeFactory typeFactory,
boolean requiresOver) |
static AggSqlFunction |
AggSqlFunction.apply(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> returnType,
FlinkTypeFactory typeFactory,
boolean requiresOver) |
static org.apache.calcite.sql.SqlFunction |
UserDefinedFunctionUtils.createAggregateSqlFunction(String name,
AggregateFunction<?,?> aggFunction,
TypeInformation<?> typeInfo,
FlinkTypeFactory typeFactory)
Create
SqlFunction for an AggregateFunction |
org.apache.calcite.sql.SqlFunction |
UserDefinedFunctionUtils$.createAggregateSqlFunction(String name,
AggregateFunction<?,?> aggFunction,
TypeInformation<?> typeInfo,
FlinkTypeFactory typeFactory)
Create
SqlFunction for an AggregateFunction |
org.apache.calcite.sql.type.SqlOperandTypeChecker |
AggSqlFunction$.createOperandTypeChecker(AggregateFunction<?,?> aggregateFunction) |
static org.apache.calcite.sql.type.SqlOperandTypeChecker |
AggSqlFunction.createOperandTypeChecker(AggregateFunction<?,?> aggregateFunction) |
org.apache.calcite.sql.type.SqlOperandTypeInference |
AggSqlFunction$.createOperandTypeInference(AggregateFunction<?,?> aggregateFunction,
FlinkTypeFactory typeFactory) |
static org.apache.calcite.sql.type.SqlOperandTypeInference |
AggSqlFunction.createOperandTypeInference(AggregateFunction<?,?> aggregateFunction,
FlinkTypeFactory typeFactory) |
static scala.Option<Class<?>[]> |
UserDefinedFunctionUtils.getAccumulateMethodSignature(AggregateFunction<?,?> function,
scala.collection.Seq<TypeInformation<?>> signature)
Returns signatures of accumulate methods matching the given signature of
TypeInformation . |
scala.Option<Class<?>[]> |
UserDefinedFunctionUtils$.getAccumulateMethodSignature(AggregateFunction<?,?> function,
scala.collection.Seq<TypeInformation<?>> signature)
Returns signatures of accumulate methods matching the given signature of
TypeInformation . |
static TypeInformation<?> |
UserDefinedFunctionUtils.getResultTypeOfAggregateFunction(AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> extractedType)
Internal method of AggregateFunction#getResultType() that does some pre-checking and uses
TypeExtractor as default return type inference. |
TypeInformation<?> |
UserDefinedFunctionUtils$.getResultTypeOfAggregateFunction(AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> extractedType)
Internal method of AggregateFunction#getResultType() that does some pre-checking and uses
TypeExtractor as default return type inference. |
Constructor and Description |
---|
AggSqlFunction(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> returnType,
FlinkTypeFactory typeFactory,
boolean requiresOver) |
Modifier and Type | Method and Description |
---|---|
static RowTypeInfo |
AggregateUtil.createAccumulatorRowType(AggregateFunction<?,?>[] aggregates) |
RowTypeInfo |
AggregateUtil$.createAccumulatorRowType(AggregateFunction<?,?>[] aggregates) |
static boolean |
AggregateUtil.doAllSupportPartialMerge(AggregateFunction<?,?>[] aggregateList)
Return true if all aggregates can be partially merged.
|
boolean |
AggregateUtil$.doAllSupportPartialMerge(AggregateFunction<?,?>[] aggregateList)
Return true if all aggregates can be partially merged.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.