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

Class WayangAggregator

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.flink.api.common.aggregators.Aggregator<org.apache.flink.types.ListValue<WayangValue>>
    public class WayangAggregator
extends java.lang.Object
implements org.apache.flink.api.common.aggregators.Aggregator<org.apache.flink.types.ListValue<WayangValue>>
    Class create a Aggregator that generate aggregatorWrapper
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void aggregate​(java.lang.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 Detail

      • WayangAggregator

        public WayangAggregator()

    • Method Detail

      • 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​(java.lang.Object t)

      • reset

        public void reset()
        Specified by:
        reset in interface org.apache.flink.api.common.aggregators.Aggregator<org.apache.flink.types.ListValue<WayangValue>>