Uses of Class
org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate

Packages that use SingleInputGate

Package	Description
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.taskmanager

Uses of SingleInputGate in org.apache.flink.runtime.io.network

Methods in org.apache.flink.runtime.io.network with parameters of type SingleInputGate

Modifier and Type	Method and Description
void	NetworkEnvironment.setupInputGate(SingleInputGate gate)

Uses of SingleInputGate in org.apache.flink.runtime.io.network.partition.consumer

Fields in org.apache.flink.runtime.io.network.partition.consumer declared as SingleInputGate

Modifier and Type	Field and Description
protected SingleInputGate	InputChannel.inputGate

Methods in org.apache.flink.runtime.io.network.partition.consumer that return SingleInputGate

Modifier and Type	Method and Description
static SingleInputGate	SingleInputGate.create(String owningTaskName, JobID jobId, ExecutionAttemptID executionId, InputGateDeploymentDescriptor igdd, NetworkEnvironment networkEnvironment, TaskActions taskActions, TaskIOMetricGroup metrics) Creates an input gate and all of its input channels.

Methods in org.apache.flink.runtime.io.network.partition.consumer with parameters of type SingleInputGate

Modifier and Type	Method and Description
static void	InputGateMetrics.registerQueueLengthMetrics(MetricGroup group, SingleInputGate gate)

Constructors in org.apache.flink.runtime.io.network.partition.consumer with parameters of type SingleInputGate

Constructor and Description
InputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, int initialBackoff, int maxBackoff, Counter numBytesIn, Counter numBuffersIn)
LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventDispatcher taskEventDispatcher, int initialBackoff, int maxBackoff, TaskIOMetricGroup metrics)
LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventDispatcher taskEventDispatcher, TaskIOMetricGroup metrics)
RemoteInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ConnectionID connectionId, ConnectionManager connectionManager, int initialBackOff, int maxBackoff, TaskIOMetricGroup metrics)
RemoteInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ConnectionID connectionId, ConnectionManager connectionManager, TaskIOMetricGroup metrics)

Uses of SingleInputGate in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager that return SingleInputGate

Modifier and Type	Method and Description
SingleInputGate[]	Task.getAllInputGates()
SingleInputGate	Task.getInputGateById(IntermediateDataSetID id)