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 |
---|---|
void |
SingleInputGate.registerBufferReceivedListener(BufferReceivedListener bufferReceivedListener) |
void |
UnionInputGate.registerBufferReceivedListener(BufferReceivedListener listener) |
abstract void |
InputGate.registerBufferReceivedListener(BufferReceivedListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
InputGateWithMetrics.registerBufferReceivedListener(BufferReceivedListener listener) |
Modifier and Type | Method and Description |
---|---|
Optional<BufferReceivedListener> |
CheckpointBarrierHandler.getBufferReceivedListener() |
Optional<BufferReceivedListener> |
CheckpointBarrierUnaligner.getBufferReceivedListener() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.