| Package | Description |
|---|---|
| org.apache.flink.runtime.execution | |
| org.apache.flink.runtime.io.network.partition.consumer | |
| org.apache.flink.runtime.taskmanager |
| Modifier and Type | Method and Description |
|---|---|
SingleInputGate[] |
RuntimeEnvironment.getAllInputGates() |
SingleInputGate |
RuntimeEnvironment.getInputGateById(IntermediateDataSetID id) |
| Modifier and Type | Field and Description |
|---|---|
protected SingleInputGate |
InputChannel.inputGate |
| Modifier and Type | Method and Description |
|---|---|
static SingleInputGate |
SingleInputGate.create(InputGateDeploymentDescriptor igdd,
NetworkEnvironment networkEnvironment)
Creates an input gate and all of its input channels.
|
| Constructor and Description |
|---|
InputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId) |
UnknownInputChannel(SingleInputGate gate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventDispatcher taskEventDispatcher,
ConnectionManager connectionManager) |
| Modifier and Type | Method and Description |
|---|---|
SingleInputGate[] |
Task.getInputGates() |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.