Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.io.network.api.writer | |
org.apache.flink.runtime.io.network.netty | |
org.apache.flink.runtime.io.network.partition | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.runtime.jobgraph | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.taskmanager |
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionType |
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionType |
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionManager
The result partition manager keeps track of all currently produced/consumed partitions of a
task manager.
|
ResultPartitionProvider |
Class and Description |
---|
ResultPartition
A result partition for data produced by a single task.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionProvider |
Class and Description |
---|
BufferAvailabilityListener
Listener interface implemented by consumers of
ResultSubpartitionView
that want to be notified of availability of further buffers. |
ResultPartition
A result partition for data produced by a single task.
|
ResultPartitionConsumableNotifier |
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionManager
The result partition manager keeps track of all currently produced/consumed partitions of a
task manager.
|
ResultPartitionProvider |
ResultPartitionType |
ResultSubpartitionView
A view to consume a
ResultSubpartition instance. |
Class and Description |
---|
BufferAvailabilityListener
Listener interface implemented by consumers of
ResultSubpartitionView
that want to be notified of availability of further buffers. |
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionManager
The result partition manager keeps track of all currently produced/consumed partitions of a
task manager.
|
Class and Description |
---|
ResultPartitionType |
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
ResultPartition
A result partition for data produced by a single task.
|
ResultPartitionConsumableNotifier |
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.