Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.streaming.runtime.io |
Modifier and Type | Method and Description |
---|---|
Optional<BufferOrEvent> |
SingleInputGate.getNextBufferOrEvent() |
Optional<BufferOrEvent> |
InputGate.getNextBufferOrEvent()
Blocking call waiting for next
BufferOrEvent . |
Optional<BufferOrEvent> |
UnionInputGate.getNextBufferOrEvent() |
Optional<BufferOrEvent> |
SingleInputGate.pollNextBufferOrEvent() |
Optional<BufferOrEvent> |
InputGate.pollNextBufferOrEvent()
Poll the
BufferOrEvent . |
Optional<BufferOrEvent> |
UnionInputGate.pollNextBufferOrEvent() |
Modifier and Type | Method and Description |
---|---|
BufferOrEvent |
BufferOrEventSequence.getNext()
Gets the next BufferOrEvent from the sequence, or
null , if the
sequence is exhausted. |
BufferOrEvent |
BufferSpiller.SpilledBufferOrEventSequence.getNext()
Deprecated.
|
BufferOrEvent |
CachedBufferBlocker.CachedBufferOrEventSequence.getNext() |
BufferOrEvent |
BarrierBuffer.getNextNonBlocked() |
BufferOrEvent |
CheckpointBarrierHandler.getNextNonBlocked()
Returns the next
BufferOrEvent that the operator may consume. |
BufferOrEvent |
BarrierTracker.getNextNonBlocked() |
Modifier and Type | Method and Description |
---|---|
void |
BufferBlocker.add(BufferOrEvent boe)
Adds a buffer or event to the blocker.
|
void |
BufferSpiller.add(BufferOrEvent boe)
Deprecated.
Adds a buffer or event to the sequence of spilled buffers and events.
|
void |
CachedBufferBlocker.add(BufferOrEvent boe) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.