org.apache.flink.runtime.shuffle

Interface ShuffleServiceFactory<SD extends ShuffleDescriptor,P extends ResultPartitionWriter,G extends IndexedInputGate>

Type Parameters:

SD - partition shuffle descriptor used for producer/consumer deployment and their data exchange.

P - type of provided result partition writers

G - type of provided input gates

All Known Implementing Classes:

NettyShuffleServiceFactory

public interface ShuffleServiceFactory<SD extends ShuffleDescriptor,P extends ResultPartitionWriter,G extends IndexedInputGate>

Interface for shuffle service factory implementations.

This component is a light-weight factory for ShuffleMaster and ShuffleEnvironment.

Method Summary

Modifier and Type	Method and Description
ShuffleEnvironment<P,G>	createShuffleEnvironment(ShuffleEnvironmentContext shuffleEnvironmentContext) Factory method to create a specific local ShuffleEnvironment implementation.
ShuffleMaster<SD>	createShuffleMaster(Configuration configuration) Factory method to create a specific ShuffleMaster implementation.

Method Detail

createShuffleMaster

ShuffleMaster<SD> createShuffleMaster(Configuration configuration)

Factory method to create a specific ShuffleMaster implementation.

Parameters:

configuration - Flink configuration

Returns:

shuffle manager implementation

createShuffleEnvironment

ShuffleEnvironment<P,G> createShuffleEnvironment(ShuffleEnvironmentContext shuffleEnvironmentContext)

Factory method to create a specific local ShuffleEnvironment implementation.

Parameters:

shuffleEnvironmentContext - local context

Returns:

local shuffle service environment implementation