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