Package org.apache.flink.table.runtime.operators.join.interval

Class RowTimeIntervalJoin

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction
    public final class RowTimeIntervalJoin
extends org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
    The function to execute row(event) time interval stream inner-join.
    See Also:
    Serialized Form

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction

        org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.Context, org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.OnTimerContext

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      long getMaxOutputDelay()
      Get the maximum interval between receiving a row and emitting it (as part of a joined result).
      void onTimer​(long timestamp, org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.OnTimerContext ctx, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)  
      void open​(org.apache.flink.api.common.functions.OpenContext openContext)  
      void processElement1​(org.apache.flink.table.data.RowData leftRow, org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.Context ctx, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)  
      void processElement2​(org.apache.flink.table.data.RowData rightRow, org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.Context ctx, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)  

      • Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

        getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

    • Field Detail

      • leftRelativeSize

        protected final long leftRelativeSize

      • rightRelativeSize

        protected final long rightRelativeSize

      • allowedLateness

        protected final long allowedLateness

      • leftOperatorTime

        protected long leftOperatorTime

      • rightOperatorTime

        protected long rightOperatorTime

    • Constructor Detail

      • RowTimeIntervalJoin

        public RowTimeIntervalJoin​(FlinkJoinType joinType,
                           long leftLowerBound,
                           long leftUpperBound,
                           long allowedLateness,
                           long minCleanUpInterval,
                           InternalTypeInfo<org.apache.flink.table.data.RowData> leftType,
                           InternalTypeInfo<org.apache.flink.table.data.RowData> rightType,
                           IntervalJoinFunction joinFunc,
                           int leftTimeIdx,
                           int rightTimeIdx)

    • Method Detail

      • getMaxOutputDelay

        public long getMaxOutputDelay()
        Get the maximum interval between receiving a row and emitting it (as part of a joined result). This is the time interval by which watermarks need to be held back.
        Returns:
        the maximum delay for the outputs

      • open

        public void open​(org.apache.flink.api.common.functions.OpenContext openContext)
          throws Exception
        Throws:
        Exception

      • close

        public void close()
           throws Exception
        Specified by:
        close in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        close in class org.apache.flink.api.common.functions.AbstractRichFunction
        Throws:
        Exception

      • processElement1

        public void processElement1​(org.apache.flink.table.data.RowData leftRow,
                            org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.Context ctx,
                            org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                     throws Exception
        Specified by:
        processElement1 in class org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
        Throws:
        Exception

      • processElement2

        public void processElement2​(org.apache.flink.table.data.RowData rightRow,
                            org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.Context ctx,
                            org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                     throws Exception
        Specified by:
        processElement2 in class org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
        Throws:
        Exception

      • onTimer

        public void onTimer​(long timestamp,
                    org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.OnTimerContext ctx,
                    org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
             throws Exception
        Overrides:
        onTimer in class org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
        Throws:
        Exception