Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.streaming.runtime.io |
Modifier and Type | Method and Description |
---|---|
Optional<BufferOrEvent> |
SingleInputGate.getNext() |
abstract Optional<BufferOrEvent> |
InputGate.getNext()
Blocking call waiting for next
BufferOrEvent . |
Optional<BufferOrEvent> |
UnionInputGate.getNext() |
Optional<BufferOrEvent> |
SingleInputGate.pollNext() |
abstract Optional<BufferOrEvent> |
InputGate.pollNext()
Poll the
BufferOrEvent . |
Optional<BufferOrEvent> |
UnionInputGate.pollNext() |
Modifier and Type | Method and Description |
---|---|
Optional<BufferOrEvent> |
InputGateWithMetrics.getNext() |
Optional<BufferOrEvent> |
InputGateWithMetrics.pollNext() |
Modifier and Type | Method and Description |
---|---|
BufferOrEvent |
BufferOrEventSequence.getNext()
Gets the next BufferOrEvent from the sequence, or
null , if the
sequence is exhausted. |
BufferOrEvent |
CachedBufferStorage.CachedBufferOrEventSequence.getNext() |
BufferOrEvent |
BufferSpiller.SpilledBufferOrEventSequence.getNext()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Optional<BufferOrEvent> |
EmptyBufferStorage.pollNext() |
Optional<BufferOrEvent> |
CheckpointedInputGate.pollNext() |
Optional<BufferOrEvent> |
AbstractBufferStorage.pollNext() |
Optional<BufferOrEvent> |
BufferStorage.pollNext() |
Optional<BufferOrEvent> |
LinkedBufferStorage.pollNext() |
Modifier and Type | Method and Description |
---|---|
void |
EmptyBufferStorage.add(BufferOrEvent boe) |
void |
CachedBufferStorage.add(BufferOrEvent boe) |
void |
BufferSpiller.add(BufferOrEvent boe)
Deprecated.
|
void |
BufferStorage.add(BufferOrEvent boe)
Adds a buffer or event to the
BufferStorage . |
void |
LinkedBufferStorage.add(BufferOrEvent boe) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.