Class StreamingDeltaJoinOperator.InputIndexAwareStreamRecordQueueEntry
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.join.deltajoin.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>
AStreamElementQueueEntrywith the input index.
-
-
Constructor Summary
Constructors Constructor Description InputIndexAwareStreamRecordQueueEntry()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcomplete(Collection<org.apache.flink.table.data.RowData> result)voidemitResult(org.apache.flink.streaming.api.operators.TimestampedCollector<org.apache.flink.table.data.RowData> output)org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>getInputElement()intgetInputIndex()booleanisDone()voidreset(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> inputRecord, int inputIndex)
-
-
-
Method Detail
-
reset
public void reset(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> inputRecord, int inputIndex)
-
isDone
public boolean isDone()
- Specified by:
isDonein interfaceorg.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:
getInputElementin interfaceorg.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:
emitResultin interfaceorg.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:
completein interfaceorg.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData>
-
getInputIndex
public int getInputIndex()
-
-