Package | Description |
---|---|
org.apache.flink.streaming.api.operators.async.queue |
Modifier and Type | Class and Description |
---|---|
class |
StreamRecordQueueEntry<OUT>
StreamElementQueueEntry implementation for StreamRecord . |
class |
WatermarkQueueEntry
StreamElementQueueEntry implementation for the Watermark . |
Modifier and Type | Method and Description |
---|---|
Collection<StreamElementQueueEntry<?>> |
UnorderedStreamElementQueue.values() |
Collection<StreamElementQueueEntry<?>> |
StreamElementQueue.values()
Return the collection of
StreamElementQueueEntry currently contained in this queue. |
Collection<StreamElementQueueEntry<?>> |
OrderedStreamElementQueue.values() |
Modifier and Type | Method and Description |
---|---|
void |
UnorderedStreamElementQueue.onCompleteHandler(StreamElementQueueEntry<?> streamElementQueueEntry)
Callback for onComplete events for the given stream element queue entry.
|
<T> void |
UnorderedStreamElementQueue.put(StreamElementQueueEntry<T> streamElementQueueEntry) |
<T> void |
StreamElementQueue.put(StreamElementQueueEntry<T> streamElementQueueEntry)
Put the given element in the queue if capacity is left.
|
<T> void |
OrderedStreamElementQueue.put(StreamElementQueueEntry<T> streamElementQueueEntry) |
<T> boolean |
UnorderedStreamElementQueue.tryPut(StreamElementQueueEntry<T> streamElementQueueEntry) |
<T> boolean |
StreamElementQueue.tryPut(StreamElementQueueEntry<T> streamElementQueueEntry)
Try to put the given element in the queue.
|
<T> boolean |
OrderedStreamElementQueue.tryPut(StreamElementQueueEntry<T> streamElementQueueEntry) |
Modifier and Type | Method and Description |
---|---|
void |
StreamElementQueueEntry.onComplete(java.util.function.Consumer<StreamElementQueueEntry<T>> completeFunction,
Executor executor)
Register the given complete function to be called once this queue entry has been completed.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.