Package org.apache.wayang.flink.compiler.criterion

Class WayangAggregator

java.lang.Object

org.apache.wayang.flink.compiler.criterion.WayangAggregator

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.aggregators.Aggregator<org.apache.flink.types.ListValue<WayangValue>>

public class WayangAggregator
extends Object
implements org.apache.flink.api.common.aggregators.Aggregator<org.apache.flink.types.ListValue<WayangValue>>

Class create a that generate aggregatorWrapper

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
WayangAggregator()

Method Summary

Modifier and Type	Method	Description
void	aggregate(Object t)
void	aggregate(org.apache.flink.types.ListValue wayangValues)
org.apache.flink.types.ListValue<WayangValue>	getAggregate()
void	reset()

Methods inherited from class java.lang.Object

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

Constructor Details

WayangAggregator

public WayangAggregator()

Method Details

getAggregate

public org.apache.flink.types.ListValue<WayangValue> getAggregate()

Specified by:

getAggregate in interface org.apache.flink.api.common.aggregators.Aggregator<org.apache.flink.types.ListValue<WayangValue>>

aggregate

public void aggregate(org.apache.flink.types.ListValue wayangValues)

Specified by:

aggregate in interface org.apache.flink.api.common.aggregators.Aggregator<org.apache.flink.types.ListValue<WayangValue>>

aggregate

public void aggregate(Object t)

reset

public void reset()

Specified by:

reset in interface org.apache.flink.api.common.aggregators.Aggregator<org.apache.flink.types.ListValue<WayangValue>>