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,
TaskStateManager taskStateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
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 CheckpointBarrierHandler |
InputProcessorUtil.createCheckpointBarrierHandler(StreamTask<?,?> checkpointedTask,
CheckpointingMode checkpointMode,
IOManager ioManager,
InputGate inputGate,
Configuration taskManagerConfig) |
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,
BufferBlocker bufferBlocker)
Creates a new checkpoint stream aligner.
|
BarrierBuffer(InputGate inputGate,
BufferBlocker bufferBlocker,
long maxBufferedBytes)
Creates a new checkpoint stream aligner.
|
BarrierTracker(InputGate inputGate) |
StreamInputProcessor(InputGate[] inputGates,
TypeSerializer<IN> inputSerializer,
StreamTask<?,?> checkpointedTask,
CheckpointingMode checkpointMode,
Object lock,
IOManager ioManager,
Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
OneInputStreamOperator<IN,?> streamOperator,
TaskIOMetricGroup metrics,
WatermarkGauge watermarkGauge) |
Constructor and Description |
---|
StreamTwoInputProcessor(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
TwoInputStreamTask<IN1,IN2,?> checkpointedTask,
CheckpointingMode checkpointMode,
Object lock,
IOManager ioManager,
Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
TwoInputStreamOperator<IN1,IN2,?> streamOperator,
TaskIOMetricGroup metrics,
WatermarkGauge input1WatermarkGauge,
WatermarkGauge input2WatermarkGauge) |
StreamTwoInputProcessor(Collection<InputGate> inputGates1,
Collection<InputGate> inputGates2,
TypeSerializer<IN1> inputSerializer1,
TypeSerializer<IN2> inputSerializer2,
TwoInputStreamTask<IN1,IN2,?> checkpointedTask,
CheckpointingMode checkpointMode,
Object lock,
IOManager ioManager,
Configuration taskManagerConfig,
StreamStatusMaintainer streamStatusMaintainer,
TwoInputStreamOperator<IN1,IN2,?> streamOperator,
TaskIOMetricGroup metrics,
WatermarkGauge input1WatermarkGauge,
WatermarkGauge input2WatermarkGauge) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.