Package 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:

Serializable, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.AggregateFunction, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Function, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.ImplementableAggFunction

@Internal
public class UdafImpl<InputT,AccumT,OutputT>
extends Object
implements org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.AggregateFunction, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.ImplementableAggFunction, Serializable

Implement AggregateFunction to take a Combine.CombineFn as UDAF.

See Also:

• Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Combine.CombineFn<InputT,AccumT,OutputT>	getCombineFn()
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.adapter.enumerable.AggImplementor	getImplementor(boolean windowContext)
protected Type	getInputType()
protected Type	getOutputType()
List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.FunctionParameter>	getParameters()
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rel.type.RelDataType	getReturnType(org.apache.beam.vendor.calcite.v1_28_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 Details

UdafImpl

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

Method Details

getCombineFn

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

getParameters

public List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.FunctionParameter> getParameters()

Specified by:

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

getImplementor

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

Specified by:

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

getReturnType

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

Specified by:

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

getInputType

protected Type getInputType()

getOutputType

protected Type getOutputType()