public class NettyShuffleServiceFactory extends Object implements ShuffleServiceFactory<NettyShuffleDescriptor,ResultPartition,SingleInputGate>
Constructor and Description |
---|
NettyShuffleServiceFactory() |
Modifier and Type | Method and Description |
---|---|
NettyShuffleEnvironment |
createShuffleEnvironment(ShuffleEnvironmentContext shuffleEnvironmentContext)
Factory method to create a specific local
ShuffleEnvironment implementation. |
NettyShuffleMaster |
createShuffleMaster(Configuration configuration)
Factory method to create a specific
ShuffleMaster implementation. |
public NettyShuffleMaster createShuffleMaster(Configuration configuration)
ShuffleServiceFactory
ShuffleMaster
implementation.createShuffleMaster
in interface ShuffleServiceFactory<NettyShuffleDescriptor,ResultPartition,SingleInputGate>
configuration
- Flink configurationpublic NettyShuffleEnvironment createShuffleEnvironment(ShuffleEnvironmentContext shuffleEnvironmentContext)
ShuffleServiceFactory
ShuffleEnvironment
implementation.createShuffleEnvironment
in interface ShuffleServiceFactory<NettyShuffleDescriptor,ResultPartition,SingleInputGate>
shuffleEnvironmentContext
- local contextCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.