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.
|
ResultSubpartitionView.AvailabilityWithBacklog
Availability of the
ResultSubpartitionView and the backlog in the corresponding
ResultSubpartition . |
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 . |
ResultSubpartitionView
A view to consume a
ResultSubpartition 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. |
BufferWithChannel
Buffer and the corresponding channel index.
|
BufferWritingResultPartition
A
ResultPartition which writes buffers directly to ResultSubpartition s. |
ChannelStateHolder
Implemented by entities that hold any kind of channel state and need a reference to the
ChannelStateWriter . |
CheckpointedResultPartition
Interface for partitions that are checkpointed, meaning they store data as part of unaligned
checkpoints.
|
CheckpointedResultSubpartition
Interface for subpartitions that are checkpointed, meaning they store data as part of unaligned
checkpoints.
|
DataSetMetaInfo
Container for meta-data of a data set.
|
JobMasterPartitionTracker
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
PartitionedFile
PartitionedFile is the persistent file type of sort-merge based blocking shuffle. |
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. |
ResultSubpartitionView.AvailabilityWithBacklog
Availability of the
ResultSubpartitionView and the backlog in the corresponding
ResultSubpartition . |
SortBuffer
Data of different channels can be appended to a
SortBuffer and after the SortBuffer is finished, the appended data can be copied from it in channel index order. |
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. |
ChannelStateHolder
Implemented by entities that hold any kind of channel state and need a reference to the
ChannelStateWriter . |
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.
|
PrioritizedDeque
A deque-like data structure that supports prioritization of elements, such they will be polled
before any non-priority elements.
|
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 |
---|
JobMasterPartitionTracker
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
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 |
---|
ClusterPartitionManager
Interface for components that manage cluster partitions.
|
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 |
---|
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.
|
ChannelStateHolder
Implemented by entities that hold any kind of channel state and need a reference to the
ChannelStateWriter . |
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 . |
Class and Description |
---|
ResultPartitionType
Type of a result partition.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.