Class StreamingDeltaJoinOperator.InputIndexAwareStreamRecordQueueEntry

  • All Implemented Interfaces:
    org.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<org.apache.flink.table.data.RowData>
    Enclosing class:
    StreamingDeltaJoinOperator

    @VisibleForTesting
    public static class StreamingDeltaJoinOperator.InputIndexAwareStreamRecordQueueEntry
    extends Object
    implements org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<org.apache.flink.table.data.RowData>
    A StreamElementQueueEntry with the input index.
    • Constructor Detail

      • InputIndexAwareStreamRecordQueueEntry

        public InputIndexAwareStreamRecordQueueEntry()
    • Method Detail

      • reset

        public void reset​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> inputRecord,
                          int inputIndex)
      • isDone

        public boolean isDone()
        Specified by:
        isDone in interface org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<org.apache.flink.table.data.RowData>
      • getInputElement

        @Nonnull
        public org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> getInputElement()
        Specified by:
        getInputElement in interface org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<org.apache.flink.table.data.RowData>
      • emitResult

        public void emitResult​(org.apache.flink.streaming.api.operators.TimestampedCollector<org.apache.flink.table.data.RowData> output)
        Specified by:
        emitResult in interface org.apache.flink.streaming.api.operators.async.queue.StreamElementQueueEntry<org.apache.flink.table.data.RowData>
      • complete

        public void complete​(Collection<org.apache.flink.table.data.RowData> result)
        Specified by:
        complete in interface org.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData>
      • getInputIndex

        public int getInputIndex()