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) |
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.
|
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.notifyInputGateNonEmpty(InputGate inputGate) |
void |
InputGateListener.notifyInputGateNonEmpty(InputGate inputGate)
Notification callback if the input gate moves from zero to non-zero
available input channels with data.
|
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,
ExecutionConfig executionConfig,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
ClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
CheckpointResponder checkpointResponder,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask) |
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)
Creates a new checkpoint stream aligner.
|
BarrierBuffer(InputGate inputGate,
IOManager ioManager,
long maxBufferedBytes)
Creates a new checkpoint stream aligner.
|
BarrierTracker(InputGate inputGate) |
StreamInputProcessor(InputGate[] inputGates,
TypeSerializer<IN> inputSerializer,
StatefulTask checkpointedTask,
CheckpointingMode checkpointMode,
Object lock,
IOManager ioManager,
Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
OneInputStreamOperator<IN,?> streamOperator) |
Constructor and Description |
---|
StreamTwoInputProcessor(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
StatefulTask checkpointedTask,
CheckpointingMode checkpointMode,
Object lock,
IOManager ioManager,
Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
TwoInputStreamOperator<IN1,IN2,?> streamOperator) |
StreamTwoInputProcessor(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
StatefulTask checkpointedTask,
CheckpointingMode checkpointMode,
Object lock,
IOManager ioManager,
Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
TwoInputStreamOperator<IN1,IN2,?> streamOperator) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.