Class and Description |
---|
ClusterPartitionManager
Interface for components that manage cluster partitions.
|
ResourceManagerPartitionTrackerFactory
Factory for
ResourceManagerPartitionTracker . |
Class and Description |
---|
ClusterPartitionManager
Interface for components that manage cluster partitions.
|
ResourceManagerPartitionTrackerFactory
Factory for
ResourceManagerPartitionTracker . |
Class and Description |
---|
ResultPartitionType
Type of a result partition.
|
Class and Description |
---|
JobMasterPartitionTracker
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionType
Type of a result partition.
|
Class and Description |
---|
PartitionProducerStateProvider
Request execution state of partition producer, the response accepts state check callbacks.
|
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.
|
ResultPartitionProvider
Interface for creating result partitions.
|
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultSubpartition
A single subpartition of a
ResultPartition instance. |
Class and Description |
---|
ResultPartition
A result partition for data produced by a single task.
|
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionProvider
Interface for creating result partitions.
|
Class and Description |
---|
AbstractPartitionTracker
Base partition tracker implementation, providing underlying data-structures for storing
partitions, their associated keys and meta-information.
|
BoundedBlockingSubpartitionType
The type of the BoundedBlockingSubpartition.
|
BufferAvailabilityListener
Listener interface implemented by consumers of
ResultSubpartitionView that want to be
notified of availability of further buffers. |
DataSetMetaInfo
Container for meta-data of a data set.
|
JobMasterPartitionTracker
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
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.
|
PartitionProducerStateProvider.ResponseHandle
Result of state query, accepts state check callbacks.
|
PartitionTracker
Utility for tracking partitions.
|
PartitionTrackerEntry
Encapsulates all information that a
PartitionTracker keeps for a partition. |
PartitionTrackerFactory.TaskExecutorGatewayLookup
Lookup function for
TaskExecutorGateway . |
PipelinedSubpartition
A pipelined in-memory only subpartition, which can be consumed once.
|
PipelinedSubpartitionView
View over a pipelined in-memory only subpartition.
|
ResourceManagerPartitionTracker
Utility for tracking and releasing partitions on the ResourceManager.
|
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.
|
ResultPartitionProvider
Interface for creating result partitions.
|
ResultPartitionType
Type 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. |
ResultSubpartitionView
A view to consume a
ResultSubpartition instance. |
TaskExecutorClusterPartitionReleaser
Interface for releasing cluster partitions on a task executor.
|
TaskExecutorPartitionInfo
Encapsulates meta-information the TaskExecutor requires to be kept for each partition.
|
TaskExecutorPartitionTracker
Utility for tracking partitions.
|
Class and Description |
---|
BufferAvailabilityListener
Listener interface implemented by consumers of
ResultSubpartitionView that want to be
notified of availability of further buffers. |
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.
|
PartitionProducerStateProvider
Request execution state of partition producer, the response accepts state check callbacks.
|
PartitionProducerStateProvider.ResponseHandle
Result of state query, accepts state check callbacks.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionManager
The result partition manager keeps track of all currently produced/consumed partitions of a task
manager.
|
ResultPartitionType
Type of a result partition.
|
Class and Description |
---|
ResultPartitionType
Type of a result partition.
|
Class and Description |
---|
ResultPartitionType
Type of a result partition.
|
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
PartitionTrackerFactory
Factory for
JobMasterPartitionTracker . |
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
ClusterPartitionManager
Interface for components that manage cluster partitions.
|
DataSetMetaInfo
Container for meta-data of a data set.
|
ResourceManagerPartitionTrackerFactory
Factory for
ResourceManagerPartitionTracker . |
Class and Description |
---|
DataSetMetaInfo
Container for meta-data of a data set.
|
Class and Description |
---|
JobMasterPartitionTracker
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
PartitionProducerStateProvider
Request execution state of partition producer, the response accepts state check callbacks.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultPartitionType
Type of a result partition.
|
Class and Description |
---|
ResultPartitionConsumableNotifier
Interface for notifications about consumable partitions.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
TaskExecutorPartitionTracker
Utility for tracking partitions.
|
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
ResultPartitionConsumableNotifier
Interface for notifications about consumable partitions.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
BoundedBlockingSubpartitionType
The type of the BoundedBlockingSubpartition.
|
PartitionProducerStateProvider
Request execution state of partition producer, the response accepts state check callbacks.
|
PartitionProducerStateProvider.ResponseHandle
Result of state query, accepts state check callbacks.
|
ResultPartitionConsumableNotifier
Interface for notifications about consumable partitions.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
ResultSubpartition
A single subpartition of a
ResultPartition instance. |
Class and Description |
---|
ResultPartitionType
Type of a result partition.
|
Class and Description |
---|
ClusterPartitionManager
Interface for components that manage cluster partitions.
|
ResourceManagerPartitionTrackerFactory
Factory for
ResourceManagerPartitionTracker . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.