Package | Description |
---|---|
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.io.checkpointing | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamTaskExternallyInducedSourceInput<T>
A subclass of
StreamTaskSourceInput for ExternallyInducedSourceReader . |
Modifier and Type | Method and Description |
---|---|
static CheckpointBarrierHandler |
InputProcessorUtil.createCheckpointBarrierHandler(CheckpointableTask toNotifyOnCheckpoint,
StreamConfig config,
SubtaskCheckpointCoordinator checkpointCoordinator,
String taskName,
List<IndexedInputGate>[] inputGates,
List<StreamTaskSourceInput<?>> sourceInputs,
MailboxExecutor mailboxExecutor,
TimerService timerService) |
Modifier and Type | Class and Description |
---|---|
class |
StreamTaskFinishedOnRestoreSourceInput<T>
A special source input implementation that immediately emit END_OF_INPUT.
|
Modifier and Type | Method and Description |
---|---|
StreamTaskSourceInput<?> |
OperatorChain.ChainedSource.getSourceTaskInput() |
StreamTaskSourceInput<?> |
OperatorChain.getSourceTaskInput(StreamConfig.SourceInputConfig sourceInput) |
Modifier and Type | Method and Description |
---|---|
List<StreamTaskSourceInput<?>> |
OperatorChain.getSourceTaskInputs() |
Constructor and Description |
---|
ChainedSource(WatermarkGaugeExposingOutput<StreamRecord<?>> chainedSourceOutput,
StreamTaskSourceInput<?> sourceTaskInput) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.