Class and Description |
---|
PartitionDescriptor
Partition descriptor for
ShuffleMaster to obtain ShuffleDescriptor . |
ShuffleDescriptor
Interface for shuffle deployment descriptor of result partition resource.
|
Class and Description |
---|
ShuffleDescriptor
Interface for shuffle deployment descriptor of result partition resource.
|
ShuffleMaster
Intermediate result partition registry to use in
JobMaster . |
Class and Description |
---|
NettyShuffleMaster
Default
ShuffleMaster for netty and local file based shuffle implementation. |
ShuffleEnvironment
Interface for the implementation of shuffle service local environment.
|
ShuffleEnvironmentContext
Local context used to create
ShuffleEnvironment . |
ShuffleIOOwnerContext
Context of shuffle input/output owner used to create partitions or gates belonging to the owner.
|
ShuffleMasterContext
Shuffle context used to create
ShuffleMaster . |
ShuffleServiceFactory
Interface for shuffle service factory implementations.
|
Class and Description |
---|
ShuffleDescriptor
Interface for shuffle deployment descriptor of result partition resource.
|
ShuffleEnvironment
Interface for the implementation of shuffle service local environment.
|
ShuffleMaster
Intermediate result partition registry to use in
JobMaster . |
Class and Description |
---|
NettyShuffleDescriptor
Default implementation of
ShuffleDescriptor for NettyShuffleMaster . |
ShuffleIOOwnerContext
Context of shuffle input/output owner used to create partitions or gates belonging to the owner.
|
Class and Description |
---|
ShuffleMaster
Intermediate result partition registry to use in
JobMaster . |
Class and Description |
---|
ShuffleDescriptor
Interface for shuffle deployment descriptor of result partition resource.
|
Class and Description |
---|
ShuffleMaster
Intermediate result partition registry to use in
JobMaster . |
Class and Description |
---|
ShuffleMaster
Intermediate result partition registry to use in
JobMaster . |
Class and Description |
---|
ShuffleMaster
Intermediate result partition registry to use in
JobMaster . |
Class and Description |
---|
JobShuffleContext
Job level shuffle context which can offer some job information like job ID and through it, the
shuffle plugin notify the job to stop tracking the lost result partitions.
|
NettyShuffleDescriptor
Default implementation of
ShuffleDescriptor for NettyShuffleMaster . |
NettyShuffleDescriptor.LocalExecutionPartitionConnectionInfo
Local partition connection information.
|
NettyShuffleDescriptor.PartitionConnectionInfo
Information for connection to partition producer for shuffle exchange.
|
PartitionDescriptor
Partition descriptor for
ShuffleMaster to obtain ShuffleDescriptor . |
ProducerDescriptor
Partition producer descriptor for
ShuffleMaster to obtain ShuffleDescriptor . |
ShuffleDescriptor
Interface for shuffle deployment descriptor of result partition resource.
|
ShuffleEnvironment
Interface for the implementation of shuffle service local environment.
|
ShuffleEnvironmentContext
Local context used to create
ShuffleEnvironment . |
ShuffleIOOwnerContext
Context of shuffle input/output owner used to create partitions or gates belonging to the owner.
|
ShuffleMaster
Intermediate result partition registry to use in
JobMaster . |
ShuffleMasterContext
Shuffle context used to create
ShuffleMaster . |
ShuffleServiceFactory
Interface for shuffle service factory implementations.
|
ShuffleServiceLoader
Utility to load the pluggable
ShuffleServiceFactory implementations. |
TaskInputsOutputsDescriptor
Describes inputs and outputs information of a task.
|
UnknownShuffleDescriptor
Unknown
ShuffleDescriptor for which the producer has not been deployed yet. |
Class and Description |
---|
ShuffleEnvironment
Interface for the implementation of shuffle service local environment.
|
Class and Description |
---|
ShuffleDescriptor
Interface for shuffle deployment descriptor of result partition resource.
|
Class and Description |
---|
ShuffleEnvironment
Interface for the implementation of shuffle service local environment.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.