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. |
Modifier and Type | Method and Description |
---|---|
static SingleCheckpointBarrierHandler |
SingleCheckpointBarrierHandler.aligned(String taskName,
AbstractInvokable toNotifyOnCheckpoint,
Clock clock,
int numOpenChannels,
java.util.function.BiFunction<Callable<?>,java.time.Duration,org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler.Cancellable> registerTimer,
CheckpointableInput... inputs) |
static SingleCheckpointBarrierHandler |
SingleCheckpointBarrierHandler.alternating(String taskName,
AbstractInvokable toNotifyOnCheckpoint,
SubtaskCheckpointCoordinator checkpointCoordinator,
Clock clock,
int numOpenChannels,
java.util.function.BiFunction<Callable<?>,java.time.Duration,org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler.Cancellable> registerTimer,
CheckpointableInput... inputs) |
static SingleCheckpointBarrierHandler |
SingleCheckpointBarrierHandler.createUnalignedCheckpointBarrierHandler(SubtaskCheckpointCoordinator checkpointCoordinator,
String taskName,
AbstractInvokable toNotifyOnCheckpoint,
Clock clock,
CheckpointableInput... inputs) |
static SingleCheckpointBarrierHandler |
SingleCheckpointBarrierHandler.unaligned(String taskName,
AbstractInvokable toNotifyOnCheckpoint,
SubtaskCheckpointCoordinator checkpointCoordinator,
Clock clock,
int numOpenChannels,
java.util.function.BiFunction<Callable<?>,java.time.Duration,org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler.Cancellable> registerTimer,
CheckpointableInput... inputs) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.