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

Packages that use InputGate

Package	Description
org.apache.flink.runtime.execution
org.apache.flink.runtime.io.network.api.reader
org.apache.flink.runtime.io.network.partition.consumer

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

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

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

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)
BufferReader(InputGate gate)
MutableRecordReader(InputGate inputGate)
RecordReader(InputGate inputGate, Class<T> recordType)

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

Classes in org.apache.flink.runtime.io.network.partition.consumer that implement InputGate

Modifier and Type	Class and Description
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.

Method parameters in org.apache.flink.runtime.io.network.partition.consumer with type arguments of type InputGate

Modifier and Type	Method and Description
void	UnionInputGate.registerListener(EventListener<InputGate> listener)
void	SingleInputGate.registerListener(EventListener<InputGate> listener)
void	InputGate.registerListener(EventListener<InputGate> listener)

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

Constructor and Description
UnionInputGate(InputGate... inputGates)