Package org.apache.wayang.flink.compiler

Class FlinkCoGroupFunction<InputType0,​InputType1,​OutputType>

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.flink.api.common.functions.CoGroupFunction<InputType0,​InputType1,​OutputType>, org.apache.flink.api.common.functions.Function
    public class FlinkCoGroupFunction<InputType0,​InputType1,​OutputType>
extends java.lang.Object
implements org.apache.flink.api.common.functions.CoGroupFunction<InputType0,​InputType1,​OutputType>
    Wrapper of CoGroupFunction of Flink for use in Wayang
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void coGroup​(java.lang.Iterable<InputType0> iterable, java.lang.Iterable<InputType1> iterable1, org.apache.flink.util.Collector<OutputType> collector)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • FlinkCoGroupFunction

        public FlinkCoGroupFunction()

    • Method Detail

      • coGroup

        public void coGroup​(java.lang.Iterable<InputType0> iterable,
                    java.lang.Iterable<InputType1> iterable1,
                    org.apache.flink.util.Collector<OutputType> collector)
             throws java.lang.Exception
        Specified by:
        coGroup in interface org.apache.flink.api.common.functions.CoGroupFunction<InputType0,​InputType1,​OutputType>
        Throws:
        java.lang.Exception