Class CrossOperator.ProjectCrossFunction<T1,​T2,​R extends org.apache.flink.api.java.tuple.Tuple>

  • Type Parameters:
    T1 -
    T2 -
    R -
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.CrossFunction<T1,​T2,​R>, org.apache.flink.api.common.functions.Function
    Enclosing class:
    CrossOperator<I1,​I2,​OUT>

    @Internal
    public static final class CrossOperator.ProjectCrossFunction<T1,​T2,​R extends org.apache.flink.api.java.tuple.Tuple>
    extends Object
    implements org.apache.flink.api.common.functions.CrossFunction<T1,​T2,​R>
    See Also:
    CrossOperator.ProjectCross, Serialized Form
    • Method Detail

      • cross

        public R cross​(T1 in1,
                       T2 in2)
        Specified by:
        cross in interface org.apache.flink.api.common.functions.CrossFunction<T1,​T2,​R extends org.apache.flink.api.java.tuple.Tuple>
      • getFields

        protected int[] getFields()
      • getIsFromFirst

        protected boolean[] getIsFromFirst()