Package | Description |
---|---|
org.apache.flink.runtime.io.network.api | |
org.apache.flink.runtime.io.network.api.reader | |
org.apache.flink.runtime.io.network.api.writer | |
org.apache.flink.runtime.io.network.buffer | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.runtime.iterative.concurrent | |
org.apache.flink.runtime.iterative.task | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskEventHandler.subscribe(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
void |
TaskEventHandler.unsubscribe(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
Modifier and Type | Method and Description |
---|---|
void |
ReaderBase.registerTaskEventListener(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
void |
AbstractReader.registerTaskEventListener(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
Modifier and Type | Class and Description |
---|---|
class |
ResultPartitionWriter
A buffer-oriented runtime result writer.
|
Modifier and Type | Method and Description |
---|---|
void |
ResultPartitionWriter.subscribeToEvent(EventListener<TaskEvent> eventListener,
Class<? extends TaskEvent> eventType) |
Modifier and Type | Method and Description |
---|---|
boolean |
BufferProvider.addListener(EventListener<Buffer> listener)
Adds a buffer availability listener to the buffer provider.
|
Modifier and Type | Method and Description |
---|---|
void |
UnionInputGate.registerListener(EventListener<InputGate> listener) |
void |
SingleInputGate.registerListener(EventListener<InputGate> listener) |
void |
InputGate.registerListener(EventListener<InputGate> listener) |
Modifier and Type | Class and Description |
---|---|
class |
SuperstepBarrier
A resettable one-shot latch.
|
Modifier and Type | Class and Description |
---|---|
class |
SyncEventHandler |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointBarrierHandler.registerCheckpointEventHandler(EventListener<CheckpointBarrier> checkpointHandler)
Registers the given event handler to be notified on successful checkpoints.
|
void |
BarrierTracker.registerCheckpointEventHandler(EventListener<CheckpointBarrier> checkpointHandler) |
void |
BarrierBuffer.registerCheckpointEventHandler(EventListener<CheckpointBarrier> checkpointHandler) |
Constructor and Description |
---|
StreamInputProcessor(InputGate[] inputGates,
TypeSerializer<IN> inputSerializer,
EventListener<CheckpointBarrier> checkpointListener,
CheckpointingMode checkpointMode,
IOManager ioManager,
boolean enableWatermarkMultiplexing) |
StreamTwoInputProcessor(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
EventListener<CheckpointBarrier> checkpointListener,
CheckpointingMode checkpointMode,
IOManager ioManager,
boolean enableWatermarkMultiplexing) |
Modifier and Type | Method and Description |
---|---|
protected EventListener<CheckpointBarrier> |
StreamTask.getCheckpointBarrierListener() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.