org.apache.beam.sdk.extensions.sql.impl.interpreter.operator

Class UdafImpl<InputT,AccumT,OutputT>

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.interpreter.operator.UdafImpl<InputT,AccumT,OutputT>

All Implemented Interfaces:

java.io.Serializable

public final class UdafImpl<InputT,AccumT,OutputT>
extends java.lang.Object
implements java.io.Serializable

Implement AggregateFunction to take a Combine.CombineFn as UDAF.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
UdafImpl(Combine.CombineFn<InputT,AccumT,OutputT> combineFn)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UdafImpl

public UdafImpl(Combine.CombineFn<InputT,AccumT,OutputT> combineFn)

Method Detail

getCombineFn

public Combine.CombineFn<InputT,AccumT,OutputT> getCombineFn()

getParameters

public java.util.List<FunctionParameter> getParameters()

getImplementor

public AggImplementor getImplementor(boolean windowContext)

getReturnType

public RelDataType getReturnType(RelDataTypeFactory typeFactory)