Interface | Description |
---|---|
BufferAvailabilityListener |
Listener interface implemented by consumers of
ResultSubpartitionView
that want to be notified of availability of further buffers. |
ResultPartitionConsumableNotifier |
Interface for notifications about consumable partitions.
|
ResultPartitionProvider |
Interface for creating result partitions.
|
ResultSubpartitionView |
A view to consume a
ResultSubpartition instance. |
Class | Description |
---|---|
ResultPartition |
A result partition for data produced by a single task.
|
ResultPartitionID |
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionManager |
The result partition manager keeps track of all currently produced/consumed partitions of a
task manager.
|
ResultPartitionMetrics |
Collects metrics of a result partition.
|
ResultSubpartition |
A single subpartition of a
ResultPartition instance. |
ResultSubpartition.BufferAndBacklog |
A combination of a
Buffer and the backlog length indicating
how many non-event buffers are available in the subpartition. |
Enum | Description |
---|---|
ResultPartitionType |
Type of a result partition.
|
Exception | Description |
---|---|
PartitionNotFoundException |
Exception for failed partition requests due to non-existing partitions.
|
ProducerFailedException |
Network-stack level Exception to notify remote receiver about a failed
partition producer.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.