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

Packages that use InputGate

Package	Description
org.apache.flink.runtime.checkpoint.channel
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.api.reader
org.apache.flink.runtime.io.network.metrics
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.taskmanager
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.checkpointing

Uses of InputGate in org.apache.flink.runtime.checkpoint.channel

Methods in org.apache.flink.runtime.checkpoint.channel with parameters of type InputGate

Modifier and Type	Method and Description
void	SequentialChannelStateReader.readInputData(InputGate[] inputGates)
void	SequentialChannelStateReaderImpl.readInputData(InputGate[] inputGates)

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

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

Modifier and Type	Method and Description
void	NettyShuffleEnvironment.registerLegacyNetworkMetrics(MetricGroup metricGroup, ResultPartitionWriter[] producedPartitions, InputGate[] inputGates) Deprecated. should be removed in future

Uses of InputGate in org.apache.flink.runtime.io.network.api.reader

Fields in org.apache.flink.runtime.io.network.api.reader declared as InputGate

Modifier and Type	Field and Description
protected InputGate	AbstractReader.inputGate The input gate to read from.

Constructors in org.apache.flink.runtime.io.network.api.reader with parameters of type InputGate

Constructor and Description
AbstractReader(InputGate inputGate)
MutableRecordReader(InputGate inputGate, String[] tmpDirectories) Creates a new MutableRecordReader that de-serializes records from the given input gate and can spill partial records to disk, if they grow large.
RecordReader(InputGate inputGate, Class<T> recordType, String[] tmpDirectories) Creates a new RecordReader that de-serializes records from the given input gate and can spill partial records to disk, if they grow large.

Uses of InputGate in org.apache.flink.runtime.io.network.metrics

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

Modifier and Type	Method and Description
static void	NettyShuffleMetricFactory.registerLegacyNetworkMetrics(boolean isDetailedMetrics, MetricGroup metricGroup, ResultPartitionWriter[] producedPartitions, InputGate[] inputGates) Deprecated. should be removed in future

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

Subclasses of InputGate in org.apache.flink.runtime.io.network.partition.consumer

Modifier and Type	Class and Description
class	IndexedInputGate An InputGate with a specific index.
class	SingleInputGate An input gate consumes one or more partitions of a single produced intermediate result.
class	UnionInputGate Input gate wrapper to union the input from multiple input gates.

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

Subclasses of InputGate in org.apache.flink.runtime.taskmanager

Modifier and Type	Class and Description
class	InputGateWithMetrics This class wraps InputGate provided by shuffle service and it is mainly used for increasing general input metrics from TaskIOMetricGroup.

Methods in org.apache.flink.runtime.taskmanager with parameters of type InputGate

Modifier and Type	Method and Description
static void	Task.setupPartitionsAndGates(ResultPartitionWriter[] producedPartitions, InputGate[] inputGates)

Uses of InputGate in org.apache.flink.streaming.runtime.io

Methods in org.apache.flink.streaming.runtime.io that return InputGate

Modifier and Type	Method and Description
static InputGate	InputGateUtil.createInputGate(List<IndexedInputGate> inputGates)

Uses of InputGate in org.apache.flink.streaming.runtime.io.checkpointing

Methods in org.apache.flink.streaming.runtime.io.checkpointing with parameters of type InputGate

Modifier and Type	Method and Description
static UpstreamRecoveryTracker	UpstreamRecoveryTracker.forInputGate(InputGate inputGate)

Constructors in org.apache.flink.streaming.runtime.io.checkpointing with parameters of type InputGate

Constructor and Description
CheckpointedInputGate(InputGate inputGate, CheckpointBarrierHandler barrierHandler, MailboxExecutor mailboxExecutor) Creates a new checkpoint stream aligner.
CheckpointedInputGate(InputGate inputGate, CheckpointBarrierHandler barrierHandler, MailboxExecutor mailboxExecutor, UpstreamRecoveryTracker upstreamRecoveryTracker)