public class SingleInputGateFactory extends Object
SingleInputGate
to use in NettyShuffleEnvironment
.Constructor and Description |
---|
SingleInputGateFactory(ResourceID taskExecutorResourceId,
NettyShuffleEnvironmentConfiguration networkConfig,
ConnectionManager connectionManager,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
NetworkBufferPool networkBufferPool) |
Modifier and Type | Method and Description |
---|---|
SingleInputGate |
create(String owningTaskName,
InputGateDeploymentDescriptor igdd,
PartitionProducerStateProvider partitionProducerStateProvider,
InputChannelMetrics metrics)
Creates an input gate and all of its input channels.
|
public SingleInputGateFactory(@Nonnull ResourceID taskExecutorResourceId, @Nonnull NettyShuffleEnvironmentConfiguration networkConfig, @Nonnull ConnectionManager connectionManager, @Nonnull ResultPartitionManager partitionManager, @Nonnull TaskEventPublisher taskEventPublisher, @Nonnull NetworkBufferPool networkBufferPool)
public SingleInputGate create(@Nonnull String owningTaskName, @Nonnull InputGateDeploymentDescriptor igdd, @Nonnull PartitionProducerStateProvider partitionProducerStateProvider, @Nonnull InputChannelMetrics metrics)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.