Class and Description |
---|
ResultPartitionType
Type of a result partition.
|
Class and Description |
---|
PartitionTracker
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 |
---|
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 . |
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 |
---|
BoundedBlockingSubpartitionType
The type of the BoundedBlockingSubpartition.
|
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.ResponseHandle
Result of state query, accepts state check callbacks.
|
PartitionTracker
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
PartitionTrackerFactory.TaskExecutorGatewayLookup
Lookup function for
TaskExecutorGateway . |
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. |
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 |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
PartitionTrackerFactory
Factory for
PartitionTracker . |
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
PartitionTracker
Utility for tracking partitions and issuing release calls to task executors and shuffle masters.
|
ResultPartitionID
Runtime identifier of a produced
IntermediateResultPartition . |
Class and Description |
---|
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.
|
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 . |
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 . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.