Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.streaming.runtime.io |
Modifier and Type | Class and Description |
---|---|
class |
IndexedInputGate
An
InputGate with a specific index. |
class |
SingleInputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Modifier and Type | Class and Description |
---|---|
class |
InputGateWithMetrics
This class wraps
InputGate provided by shuffle service and it is mainly used for
increasing general input metrics from TaskIOMetricGroup . |
Modifier and Type | Class and Description |
---|---|
class |
StreamTaskExternallyInducedSourceInput<T>
A subclass of
StreamTaskSourceInput for ExternallyInducedSourceReader . |
class |
StreamTaskSourceInput<T>
Implementation of
StreamTaskInput that reads data from the SourceOperator and
returns the InputStatus to indicate whether the source state is available, unavailable or
finished. |
Constructor and Description |
---|
AlignedController(CheckpointableInput... inputs) |
UnalignedController(SubtaskCheckpointCoordinator checkpointCoordinator,
CheckpointableInput... inputs) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.