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

Class UdafImpl<InputT,AccumT,OutputT>

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.AggregateFunction, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.ImplementableAggFunction

@Experimental
 @Internal
public class UdafImpl<InputT,AccumT,OutputT>
extends java.lang.Object
implements org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.AggregateFunction, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.ImplementableAggFunction, 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()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.AggImplementor	getImplementor(boolean windowContext)
protected java.lang.reflect.Type	getInputType()
protected java.lang.reflect.Type	getOutputType()
java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.FunctionParameter>	getParameters()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType	getReturnType(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.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<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.FunctionParameter> getParameters()

Specified by:

getParameters in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function

getImplementor

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.AggImplementor getImplementor(boolean windowContext)

Specified by:

getImplementor in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.ImplementableAggFunction

getReturnType

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType getReturnType(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)

Specified by:

getReturnType in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.AggregateFunction

getInputType

protected java.lang.reflect.Type getInputType()

getOutputType

protected java.lang.reflect.Type getOutputType()