public class SingleInputGateFactory extends Object
SingleInputGate
to use in NettyShuffleEnvironment
.Modifier and Type | Class and Description |
---|---|
protected static class |
SingleInputGateFactory.ChannelStatistics
Statistics of input channels.
|
Modifier and Type | Field and Description |
---|---|
protected int |
configuredNetworkBuffersPerChannel |
protected ConnectionManager |
connectionManager |
protected NetworkBufferPool |
networkBufferPool |
protected ResultPartitionManager |
partitionManager |
protected int |
partitionRequestInitialBackoff |
protected int |
partitionRequestMaxBackoff |
protected TaskEventPublisher |
taskEventPublisher |
protected ResourceID |
taskExecutorResourceId |
Constructor and Description |
---|
SingleInputGateFactory(ResourceID taskExecutorResourceId,
NettyShuffleEnvironmentConfiguration networkConfig,
ConnectionManager connectionManager,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
NetworkBufferPool networkBufferPool) |
Modifier and Type | Method and Description |
---|---|
SingleInputGate |
create(ShuffleIOOwnerContext owner,
int gateIndex,
InputGateDeploymentDescriptor igdd,
PartitionProducerStateProvider partitionProducerStateProvider,
InputChannelMetrics metrics)
Creates an input gate and all of its input channels.
|
protected InputChannel |
createKnownInputChannel(SingleInputGate inputGate,
int index,
int buffersPerChannel,
NettyShuffleDescriptor inputChannelDescriptor,
int consumedSubpartitionIndex,
SingleInputGateFactory.ChannelStatistics channelStatistics,
InputChannelMetrics metrics) |
@Nonnull protected final ResourceID taskExecutorResourceId
protected final int partitionRequestInitialBackoff
protected final int partitionRequestMaxBackoff
@Nonnull protected final ConnectionManager connectionManager
@Nonnull protected final ResultPartitionManager partitionManager
@Nonnull protected final TaskEventPublisher taskEventPublisher
@Nonnull protected final NetworkBufferPool networkBufferPool
protected final int configuredNetworkBuffersPerChannel
public SingleInputGateFactory(@Nonnull ResourceID taskExecutorResourceId, @Nonnull NettyShuffleEnvironmentConfiguration networkConfig, @Nonnull ConnectionManager connectionManager, @Nonnull ResultPartitionManager partitionManager, @Nonnull TaskEventPublisher taskEventPublisher, @Nonnull NetworkBufferPool networkBufferPool)
public SingleInputGate create(@Nonnull ShuffleIOOwnerContext owner, int gateIndex, @Nonnull InputGateDeploymentDescriptor igdd, @Nonnull PartitionProducerStateProvider partitionProducerStateProvider, @Nonnull InputChannelMetrics metrics)
@VisibleForTesting protected InputChannel createKnownInputChannel(SingleInputGate inputGate, int index, int buffersPerChannel, NettyShuffleDescriptor inputChannelDescriptor, int consumedSubpartitionIndex, SingleInputGateFactory.ChannelStatistics channelStatistics, InputChannelMetrics metrics)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.