org.apache.flink.runtime.io.network.partition.consumer

Class SingleInputGateFactory

java.lang.Object

org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateFactory

public class SingleInputGateFactory
extends Object

Factory for SingleInputGate to use in NettyShuffleEnvironment.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	SingleInputGateFactory.ChannelStatistics Statistics of input channels.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	configuredNetworkBuffersPerChannel
protected ConnectionManager	connectionManager
protected NetworkBufferPool	networkBufferPool
protected ResultPartitionManager	partitionManager
protected int	partitionRequestInitialBackoff
protected int	partitionRequestListenerTimeout
protected int	partitionRequestMaxBackoff
protected TaskEventPublisher	taskEventPublisher
protected ResourceID	taskExecutorResourceId

Constructor Summary

Constructors

Constructor and Description
SingleInputGateFactory(ResourceID taskExecutorResourceId, NettyShuffleEnvironmentConfiguration networkConfig, ConnectionManager connectionManager, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, NetworkBufferPool networkBufferPool, TieredStorageConfiguration tieredStorageConfiguration, TieredStorageNettyServiceImpl tieredStorageNettyService)

Method Summary

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, ResultSubpartitionIndexSet subpartitionIndexSet, SingleInputGateFactory.ChannelStatistics channelStatistics, InputChannelMetrics metrics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

taskExecutorResourceId

@Nonnull
protected final ResourceID taskExecutorResourceId

partitionRequestInitialBackoff

protected final int partitionRequestInitialBackoff

partitionRequestMaxBackoff

protected final int partitionRequestMaxBackoff

partitionRequestListenerTimeout

protected final int partitionRequestListenerTimeout

connectionManager

@Nonnull
protected final ConnectionManager connectionManager

partitionManager

@Nonnull
protected final ResultPartitionManager partitionManager

taskEventPublisher

@Nonnull
protected final TaskEventPublisher taskEventPublisher

networkBufferPool

@Nonnull
protected final NetworkBufferPool networkBufferPool

configuredNetworkBuffersPerChannel

protected final int configuredNetworkBuffersPerChannel

Constructor Detail

SingleInputGateFactory

public SingleInputGateFactory(@Nonnull
                              ResourceID taskExecutorResourceId,
                              @Nonnull
                              NettyShuffleEnvironmentConfiguration networkConfig,
                              @Nonnull
                              ConnectionManager connectionManager,
                              @Nonnull
                              ResultPartitionManager partitionManager,
                              @Nonnull
                              TaskEventPublisher taskEventPublisher,
                              @Nonnull
                              NetworkBufferPool networkBufferPool,
                              @Nullable
                              TieredStorageConfiguration tieredStorageConfiguration,
                              @Nullable
                              TieredStorageNettyServiceImpl tieredStorageNettyService)

Method Detail

create

public SingleInputGate create(@Nonnull
                              ShuffleIOOwnerContext owner,
                              int gateIndex,
                              @Nonnull
                              InputGateDeploymentDescriptor igdd,
                              @Nonnull
                              PartitionProducerStateProvider partitionProducerStateProvider,
                              @Nonnull
                              InputChannelMetrics metrics)

Creates an input gate and all of its input channels.

createKnownInputChannel

@VisibleForTesting
protected InputChannel createKnownInputChannel(SingleInputGate inputGate,
                                                                  int index,
                                                                  int buffersPerChannel,
                                                                  NettyShuffleDescriptor inputChannelDescriptor,
                                                                  ResultSubpartitionIndexSet subpartitionIndexSet,
                                                                  SingleInputGateFactory.ChannelStatistics channelStatistics,
                                                                  InputChannelMetrics metrics)