Modifier and Type | Method and Description |
---|---|
String |
CodeGenerator.addReusableFunction(UserDefinedFunction function)
Adds a reusable
UserDefinedFunction to the member area of the generated Function . |
Modifier and Type | Class and Description |
---|---|
class |
AggregateFunction<T,ACC>
Base class for User-Defined Aggregates.
|
class |
ScalarFunction
Base class for a user-defined scalar function.
|
class |
TableFunction<T>
Base class for a user-defined table function (UDTF).
|
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 |
---|---|
static UserDefinedFunction |
UserDefinedFunctionUtils.deserialize(String data) |
UserDefinedFunction |
UserDefinedFunctionUtils$.deserialize(String data) |
Modifier and Type | Method and Description |
---|---|
static Method[] |
UserDefinedFunctionUtils.checkAndExtractMethods(UserDefinedFunction function,
String methodName)
Extracts methods and throws a
ValidationException if no implementation
can be found, or implementation does not match the requirements. |
Method[] |
UserDefinedFunctionUtils$.checkAndExtractMethods(UserDefinedFunction function,
String methodName)
Extracts methods and throws a
ValidationException if no implementation
can be found, or implementation does not match the requirements. |
static scala.Option<Class<?>[]> |
UserDefinedFunctionUtils.getEvalMethodSignature(UserDefinedFunction function,
scala.collection.Seq<TypeInformation<?>> signature)
Returns signatures of eval methods matching the given signature of
TypeInformation . |
scala.Option<Class<?>[]> |
UserDefinedFunctionUtils$.getEvalMethodSignature(UserDefinedFunction function,
scala.collection.Seq<TypeInformation<?>> signature)
Returns signatures of eval methods matching the given signature of
TypeInformation . |
static Class<?>[][] |
UserDefinedFunctionUtils.getMethodSignatures(UserDefinedFunction function,
String methodName) |
Class<?>[][] |
UserDefinedFunctionUtils$.getMethodSignatures(UserDefinedFunction function,
String methodName) |
static TypeInformation<?>[] |
UserDefinedFunctionUtils.getParameterTypes(UserDefinedFunction function,
Class<?>[] signature) |
TypeInformation<?>[] |
UserDefinedFunctionUtils$.getParameterTypes(UserDefinedFunction function,
Class<?>[] signature) |
static scala.Option<Method> |
UserDefinedFunctionUtils.getUserDefinedMethod(UserDefinedFunction function,
String methodName,
Class<?>[] methodSignature)
Returns user defined method matching the given name and signature.
|
scala.Option<Method> |
UserDefinedFunctionUtils$.getUserDefinedMethod(UserDefinedFunction function,
String methodName,
Class<?>[] methodSignature)
Returns user defined method matching the given name and signature.
|
static boolean |
UserDefinedFunctionUtils.ifMethodExistInFunction(String method,
UserDefinedFunction function)
Check if a given method exists in the given function
|
boolean |
UserDefinedFunctionUtils$.ifMethodExistInFunction(String method,
UserDefinedFunction function)
Check if a given method exists in the given function
|
static String |
UserDefinedFunctionUtils.serialize(UserDefinedFunction function) |
String |
UserDefinedFunctionUtils$.serialize(UserDefinedFunction function) |
static String |
UserDefinedFunctionUtils.signaturesToString(UserDefinedFunction function,
String name)
Prints all signatures of methods with given name in a class.
|
String |
UserDefinedFunctionUtils$.signaturesToString(UserDefinedFunction function,
String name)
Prints all signatures of methods with given name in a class.
|
Modifier and Type | Class and Description |
---|---|
class |
BooleanExplodeTableFunc |
class |
ByteExplodeTableFunc |
class |
DoubleExplodeTableFunc |
class |
FloatExplodeTableFunc |
class |
IntExplodeTableFunc |
class |
LongExplodeTableFunc |
class |
ObjectExplodeTableFunc |
class |
ShortExplodeTableFunc |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.