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

Packages that use IndexedInputGate

Package	Description
org.apache.flink.runtime.execution
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.taskmanager
org.apache.flink.state.api.runtime
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.runtime.tasks.bufferdebloat

Uses of IndexedInputGate in org.apache.flink.runtime.execution

Methods in org.apache.flink.runtime.execution that return IndexedInputGate

Modifier and Type	Method and Description
IndexedInputGate[]	Environment.getAllInputGates()
IndexedInputGate	Environment.getInputGate(int index)

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

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

Modifier and Type	Class and Description
class	SingleInputGate An input gate consumes one or more partitions of a single produced intermediate result.

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

Constructor and Description
UnionInputGate(IndexedInputGate... inputGates)

Uses of IndexedInputGate in org.apache.flink.runtime.shuffle

Classes in org.apache.flink.runtime.shuffle with type parameters of type IndexedInputGate

Modifier and Type	Interface and Description
interface	ShuffleEnvironment<P extends ResultPartitionWriter,G extends IndexedInputGate> Interface for the implementation of shuffle service local environment.
interface	ShuffleServiceFactory<SD extends ShuffleDescriptor,P extends ResultPartitionWriter,G extends IndexedInputGate> Interface for shuffle service factory implementations.

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

Subclasses of IndexedInputGate 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 that return IndexedInputGate

Modifier and Type	Method and Description
IndexedInputGate[]	RuntimeEnvironment.getAllInputGates()
IndexedInputGate	RuntimeEnvironment.getInputGate(int index)

Constructors in org.apache.flink.runtime.taskmanager with parameters of type IndexedInputGate

Constructor and Description
InputGateWithMetrics(IndexedInputGate inputGate, Counter numBytesIn, ThroughputCalculator throughputCalculator)
RuntimeEnvironment(JobID jobId, JobVertexID jobVertexId, ExecutionAttemptID executionId, ExecutionConfig executionConfig, TaskInfo taskInfo, Configuration jobConfiguration, Configuration taskConfiguration, UserCodeClassLoader userCodeClassLoader, MemoryManager memManager, IOManager ioManager, BroadcastVariableManager bcVarManager, TaskStateManager taskStateManager, GlobalAggregateManager aggregateManager, AccumulatorRegistry accumulatorRegistry, TaskKvStateRegistry kvStateRegistry, InputSplitProvider splitProvider, Map<String,Future<Path>> distCacheEntries, ResultPartitionWriter[] writers, IndexedInputGate[] inputGates, TaskEventDispatcher taskEventDispatcher, CheckpointResponder checkpointResponder, TaskOperatorEventGateway operatorEventGateway, TaskManagerRuntimeInfo taskManagerInfo, TaskMetricGroup metrics, Task containingTask, ExternalResourceInfoProvider externalResourceInfoProvider, ThroughputCalculator throughputCalculator)

Uses of IndexedInputGate in org.apache.flink.state.api.runtime

Methods in org.apache.flink.state.api.runtime that return IndexedInputGate

Modifier and Type	Method and Description
IndexedInputGate[]	SavepointEnvironment.getAllInputGates()
IndexedInputGate	SavepointEnvironment.getInputGate(int index)

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

Method parameters in org.apache.flink.streaming.runtime.io with type arguments of type IndexedInputGate

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

Uses of IndexedInputGate in org.apache.flink.streaming.runtime.tasks

Method parameters in org.apache.flink.streaming.runtime.tasks with type arguments of type IndexedInputGate

Modifier and Type	Method and Description
protected abstract void	AbstractTwoInputStreamTask.createInputProcessor(List<IndexedInputGate> inputGates1, List<IndexedInputGate> inputGates2, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners)
protected abstract void	AbstractTwoInputStreamTask.createInputProcessor(List<IndexedInputGate> inputGates1, List<IndexedInputGate> inputGates2, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners)
protected void	TwoInputStreamTask.createInputProcessor(List<IndexedInputGate> inputGates1, List<IndexedInputGate> inputGates2, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners)
protected void	TwoInputStreamTask.createInputProcessor(List<IndexedInputGate> inputGates1, List<IndexedInputGate> inputGates2, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners)

Uses of IndexedInputGate in org.apache.flink.streaming.runtime.tasks.bufferdebloat

Constructors in org.apache.flink.streaming.runtime.tasks.bufferdebloat with parameters of type IndexedInputGate

Constructor and Description
BufferDebloater(Configuration taskConfig, IndexedInputGate[] inputGates)