Interface | Description |
---|---|
BufferAvailabilityListener |
Listener interface implemented by consumers of
ResultSubpartitionView
that want to be notified of availability of further buffers. |
JobMasterPartitionTracker |
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
PartitionProducerStateProvider |
Request execution state of partition producer, the response accepts state check callbacks.
|
PartitionProducerStateProvider.ResponseHandle |
Result of state query, accepts state check callbacks.
|
PartitionTracker<K,M> |
Utility for tracking partitions.
|
PartitionTrackerFactory |
Factory for
JobMasterPartitionTracker . |
PartitionTrackerFactory.TaskExecutorGatewayLookup |
Lookup function for
TaskExecutorGateway . |
ResultPartitionConsumableNotifier |
Interface for notifications about consumable partitions.
|
ResultPartitionProvider |
Interface for creating result partitions.
|
ResultSubpartitionView |
A view to consume a
ResultSubpartition instance. |
TaskExecutorPartitionTracker |
Utility for tracking partitions.
|
Class | Description |
---|---|
AbstractPartitionTracker<K,M> |
Base partition tracker implementation, providing underlying data-structures for storing partitions, their associated
keys and meta-information.
|
JobMasterPartitionTrackerImpl |
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
NoOpResultSubpartitionView |
A dummy implementation of the
ResultSubpartitionView . |
PageSizeUtil |
Utility for accessing the system page size.
|
PartitionTrackerEntry<K,M> |
Encapsulates all information that a
PartitionTracker keeps for a partition. |
ReleaseOnConsumptionResultPartition |
ResultPartition that releases itself once all subpartitions have been consumed.
|
ResultPartition |
A result partition for data produced by a single task.
|
ResultPartitionFactory |
Factory for
ResultPartition to use in NettyShuffleEnvironment . |
ResultPartitionID |
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionManager |
The result partition manager keeps track of all currently produced/consumed partitions of a
task manager.
|
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. |
TaskExecutorPartitionInfo |
Encapsulates meta-information the TaskExecutor requires to be kept for each partition.
|
TaskExecutorPartitionTrackerImpl |
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
Enum | Description |
---|---|
BoundedBlockingSubpartitionType |
The type of the BoundedBlockingSubpartition.
|
ResultPartitionType |
Type of a result partition.
|
Exception | Description |
---|---|
PartitionException |
Exception for covering all the scenarios of consuming partition failure
which causes the consumer task failed, and the job master would decide
whether to restart the producer based on this exception.
|
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.