Modifier and Type | Method and Description |
---|---|
<T,ACC> void |
FunctionCatalog.registerAggregateFunction(String name,
UserDefinedAggregateFunction<T,ACC> function,
TypeInformation<T> resultType,
TypeInformation<ACC> accType) |
Modifier and Type | Class and Description |
---|---|
class |
AggregateFunction<T,ACC>
Base class for user-defined aggregates.
|
class |
TableAggregateFunction<T,ACC>
Base class for user-defined table aggregates.
|
Modifier and Type | Method and Description |
---|---|
static <T,ACC> TypeInformation<ACC> |
UserFunctionsTypeHelper.getAccumulatorTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<ACC> |
UserFunctionsTypeHelper.getAccumulatorTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction,
TypeInformation<ACC> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<T> |
UserFunctionsTypeHelper.getReturnTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<T> |
UserFunctionsTypeHelper.getReturnTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction,
TypeInformation<T> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.