Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
BatchTableEnvironment.registerFunction(String name,
AggregateFunction<T,ACC> aggregateFunction)
Registers an
AggregateFunction under a unique name in the TableEnvironment's catalog. |
<T,ACC> void |
StreamTableEnvironment.registerFunction(String name,
AggregateFunction<T,ACC> aggregateFunction)
Registers an
AggregateFunction under a unique name in the TableEnvironment's catalog. |
Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
StreamTableEnvironmentImpl.registerFunction(String name,
AggregateFunction<T,ACC> aggregateFunction) |
Modifier and Type | Method and Description |
---|---|
AggregateFunction<?,?> |
AggregateFunctionDefinition.getAggregateFunction() |
Constructor and Description |
---|
AggregateFunctionDefinition(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> resultTypeInfo,
TypeInformation<?> accTypeInfo) |
Modifier and Type | Class and Description |
---|---|
class |
HiveGenericUDAF
|
Modifier and Type | Class and Description |
---|---|
class |
CollectAggFunction<T>
Aggregate function for COLLECT.
|
class |
FirstValueAggFunction<T>
built-in FirstValue aggregate function.
|
static class |
FirstValueAggFunction.BooleanFirstValueAggFunction
Built-in Boolean FirstValue aggregate function.
|
static class |
FirstValueAggFunction.ByteFirstValueAggFunction
Built-in Byte FirstValue aggregate function.
|
static class |
FirstValueAggFunction.DecimalFirstValueAggFunction
Built-in Decimal FirstValue aggregate function.
|
static class |
FirstValueAggFunction.DoubleFirstValueAggFunction
Built-in Double FirstValue aggregate function.
|
static class |
FirstValueAggFunction.FloatFirstValueAggFunction
Built-in Float FirstValue aggregate function.
|
static class |
FirstValueAggFunction.IntFirstValueAggFunction
Built-in Int FirstValue aggregate function.
|
static class |
FirstValueAggFunction.LongFirstValueAggFunction
Built-in Long FirstValue aggregate function.
|
static class |
FirstValueAggFunction.ShortFirstValueAggFunction
Built-in Short FirstValue aggregate function.
|
static class |
FirstValueAggFunction.StringFirstValueAggFunction
Built-in String FirstValue aggregate function.
|
class |
FirstValueWithRetractAggFunction<T>
built-in FirstValue with retraction aggregate function.
|
static class |
FirstValueWithRetractAggFunction.BooleanFirstValueWithRetractAggFunction
Built-in Boolean FirstValue with retract aggregate function.
|
static class |
FirstValueWithRetractAggFunction.ByteFirstValueWithRetractAggFunction
Built-in Byte FirstValue with retract aggregate function.
|
static class |
FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction
Built-in Decimal FirstValue with retract aggregate function.
|
static class |
FirstValueWithRetractAggFunction.DoubleFirstValueWithRetractAggFunction
Built-in Double FirstValue with retract aggregate function.
|
static class |
FirstValueWithRetractAggFunction.FloatFirstValueWithRetractAggFunction
Built-in Float FirstValue with retract aggregate function.
|
static class |
FirstValueWithRetractAggFunction.IntFirstValueWithRetractAggFunction
Built-in Int FirstValue with retract aggregate function.
|
static class |
FirstValueWithRetractAggFunction.LongFirstValueWithRetractAggFunction
Built-in Long FirstValue with retract aggregate function.
|
static class |
FirstValueWithRetractAggFunction.ShortFirstValueWithRetractAggFunction
Built-in Short FirstValue with retract aggregate function.
|
static class |
FirstValueWithRetractAggFunction.StringFirstValueWithRetractAggFunction
Built-in String FirstValue with retract aggregate function.
|
class |
LastValueAggFunction<T>
built-in LastValue aggregate function.
|
static class |
LastValueAggFunction.BooleanLastValueAggFunction
Built-in Boolean LastValue aggregate function.
|
static class |
LastValueAggFunction.ByteLastValueAggFunction
Built-in Byte LastValue aggregate function.
|
static class |
LastValueAggFunction.DecimalLastValueAggFunction
Built-in Decimal LastValue aggregate function.
|
static class |
LastValueAggFunction.DoubleLastValueAggFunction
Built-in Double LastValue aggregate function.
|
static class |
LastValueAggFunction.FloatLastValueAggFunction
Built-in Float LastValue aggregate function.
|
static class |
LastValueAggFunction.IntLastValueAggFunction
Built-in Int LastValue aggregate function.
|
static class |
LastValueAggFunction.LongLastValueAggFunction
Built-in Long LastValue aggregate function.
|
static class |
LastValueAggFunction.ShortLastValueAggFunction
Built-in Short LastValue aggregate function.
|
static class |
LastValueAggFunction.StringLastValueAggFunction
Built-in String LastValue aggregate function.
|
class |
LastValueWithRetractAggFunction<T>
built-in LastValue with retraction aggregate function.
|
static class |
LastValueWithRetractAggFunction.BooleanLastValueWithRetractAggFunction
Built-in Boolean LastValue with retract aggregate function.
|
static class |
LastValueWithRetractAggFunction.ByteLastValueWithRetractAggFunction
Built-in Byte LastValue with retract aggregate function.
|
static class |
LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction
Built-in Decimal LastValue with retract aggregate function.
|
static class |
LastValueWithRetractAggFunction.DoubleLastValueWithRetractAggFunction
Built-in Double LastValue with retract aggregate function.
|
static class |
LastValueWithRetractAggFunction.FloatLastValueWithRetractAggFunction
Built-in Float LastValue with retract aggregate function.
|
static class |
LastValueWithRetractAggFunction.IntLastValueWithRetractAggFunction
Built-in Int LastValue with retract aggregate function.
|
static class |
LastValueWithRetractAggFunction.LongLastValueWithRetractAggFunction
Built-in Long LastValue with retract aggregate function.
|
static class |
LastValueWithRetractAggFunction.ShortLastValueWithRetractAggFunction
Built-in Short LastValue with retract aggregate function.
|
static class |
LastValueWithRetractAggFunction.StringLastValueWithRetractAggFunction
Built-in String LastValue with retract aggregate function.
|
class |
ListAggWithRetractAggFunction
built-in listagg with retraction aggregate function.
|
class |
ListAggWsWithRetractAggFunction
built-in listAggWs with retraction aggregate function.
|
class |
MaxWithRetractAggFunction<T extends Comparable>
built-in Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.BooleanMaxWithRetractAggFunction
Built-in Boolean Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.ByteMaxWithRetractAggFunction
Built-in Byte Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.DateMaxWithRetractAggFunction
Built-in Date Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction
Built-in Big Decimal Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.DoubleMaxWithRetractAggFunction
Built-in Double Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.FloatMaxWithRetractAggFunction
Built-in Float Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.IntMaxWithRetractAggFunction
Built-in Int Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.LongMaxWithRetractAggFunction
Built-in Long Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.ShortMaxWithRetractAggFunction
Built-in Short Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.StringMaxWithRetractAggFunction
Built-in String Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.TimeMaxWithRetractAggFunction
Built-in Time Max with retraction aggregate function.
|
static class |
MaxWithRetractAggFunction.TimestampMaxWithRetractAggFunction
Built-in Timestamp Max with retraction aggregate function.
|
class |
MinWithRetractAggFunction<T extends Comparable>
built-in Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.BooleanMinWithRetractAggFunction
Built-in Boolean Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.ByteMinWithRetractAggFunction
Built-in Byte Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.DateMinWithRetractAggFunction
Built-in Date Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.DecimalMinWithRetractAggFunction
Built-in Big Decimal Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.DoubleMinWithRetractAggFunction
Built-in Double Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.FloatMinWithRetractAggFunction
Built-in Float Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.IntMinWithRetractAggFunction
Built-in Int Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.LongMinWithRetractAggFunction
Built-in Long Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.ShortMinWithRetractAggFunction
Built-in Short Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.StringMinWithRetractAggFunction
Built-in String Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.TimeMinWithRetractAggFunction
Built-in Time Min with retraction aggregate function.
|
static class |
MinWithRetractAggFunction.TimestampMinWithRetractAggFunction
Built-in Timestamp Min with retraction aggregate function.
|
Modifier and Type | Method and Description |
---|---|
AggregateFunction |
HiveAggSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
Constructor and Description |
---|
HiveAggSqlFunction(FunctionIdentifier identifier,
AggregateFunction aggregateFunction,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory)
Deprecated.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.