Modifier and Type | Method and Description |
---|---|
InputGate[] |
Environment.getAllInputGates() |
InputGate |
Environment.getInputGate(int index) |
Modifier and Type | Field and Description |
---|---|
protected InputGate |
AbstractReader.inputGate
The input gate to read from.
|
Constructor and Description |
---|
AbstractReader(InputGate inputGate) |
BufferReader(InputGate gate) |
MutableRecordReader(InputGate inputGate) |
RecordReader(InputGate inputGate,
Class<T> recordType) |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
UnionInputGate.registerListener(EventListener<InputGate> listener) |
void |
SingleInputGate.registerListener(EventListener<InputGate> listener) |
void |
InputGate.registerListener(EventListener<InputGate> listener) |
Constructor and Description |
---|
UnionInputGate(InputGate... inputGates) |
Modifier and Type | Method and Description |
---|---|
InputGate[] |
RuntimeEnvironment.getAllInputGates() |
InputGate |
RuntimeEnvironment.getInputGate(int index) |
Constructor and Description |
---|
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
ClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
AccumulatorRegistry accumulatorRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
ActorGateway jobManager,
TaskManagerRuntimeInfo taskManagerInfo) |
Modifier and Type | Method and Description |
---|---|
static InputGate |
InputGateUtil.createInputGate(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2) |
static InputGate |
InputGateUtil.createInputGate(InputGate[] inputGates) |
Modifier and Type | Method and Description |
---|---|
static InputGate |
InputGateUtil.createInputGate(InputGate[] inputGates) |
Modifier and Type | Method and Description |
---|---|
static InputGate |
InputGateUtil.createInputGate(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2) |
static InputGate |
InputGateUtil.createInputGate(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2) |
Constructor and Description |
---|
BarrierBuffer(InputGate inputGate,
IOManager ioManager) |
BarrierTracker(InputGate inputGate) |
StreamInputProcessor(InputGate[] inputGates,
TypeSerializer<IN> inputSerializer,
EventListener<CheckpointBarrier> checkpointListener,
CheckpointingMode checkpointMode,
IOManager ioManager,
boolean enableWatermarkMultiplexing) |
Constructor and Description |
---|
StreamTwoInputProcessor(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
EventListener<CheckpointBarrier> checkpointListener,
CheckpointingMode checkpointMode,
IOManager ioManager,
boolean enableWatermarkMultiplexing) |
StreamTwoInputProcessor(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
EventListener<CheckpointBarrier> checkpointListener,
CheckpointingMode checkpointMode,
IOManager ioManager,
boolean enableWatermarkMultiplexing) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.