public final class UdafImpl<InputT,AccumT,OutputT>
extends java.lang.Object
implements java.io.Serializable
AggregateFunction
to take a Combine.CombineFn
as UDAF.Constructor and Description |
---|
UdafImpl(Combine.CombineFn<InputT,AccumT,OutputT> combineFn) |
Modifier and Type | Method and Description |
---|---|
Combine.CombineFn<InputT,AccumT,OutputT> |
getCombineFn() |
AggImplementor |
getImplementor(boolean windowContext) |
java.util.List<FunctionParameter> |
getParameters() |
RelDataType |
getReturnType(RelDataTypeFactory typeFactory) |
public UdafImpl(Combine.CombineFn<InputT,AccumT,OutputT> combineFn)
public Combine.CombineFn<InputT,AccumT,OutputT> getCombineFn()
public java.util.List<FunctionParameter> getParameters()
public AggImplementor getImplementor(boolean windowContext)
public RelDataType getReturnType(RelDataTypeFactory typeFactory)