Package | Description |
---|---|
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 |
CheckpointBarrierTracker
The
CheckpointBarrierTracker keeps track of what checkpoint barriers have been received
from which input channels. |
class |
SingleCheckpointBarrierHandler
SingleCheckpointBarrierHandler is used for triggering checkpoint while reading the first
barrier and keeping track of the number of received barriers and consumed barriers. |
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 | Method and Description |
---|---|
static CheckpointedInputGate[] |
InputProcessorUtil.createCheckpointedMultipleInputGate(MailboxExecutor mailboxExecutor,
List<IndexedInputGate>[] inputGates,
TaskIOMetricGroup taskIOMetricGroup,
CheckpointBarrierHandler barrierHandler,
StreamConfig config) |
Constructor and Description |
---|
CheckpointedInputGate(InputGate inputGate,
CheckpointBarrierHandler barrierHandler,
MailboxExecutor mailboxExecutor)
Creates a new checkpoint stream aligner.
|
CheckpointedInputGate(InputGate inputGate,
CheckpointBarrierHandler barrierHandler,
MailboxExecutor mailboxExecutor,
UpstreamRecoveryTracker upstreamRecoveryTracker) |
Modifier and Type | Method and Description |
---|---|
protected Optional<CheckpointBarrierHandler> |
OneInputStreamTask.getCheckpointBarrierHandler() |
protected Optional<CheckpointBarrierHandler> |
TwoInputStreamTask.getCheckpointBarrierHandler() |
protected Optional<CheckpointBarrierHandler> |
MultipleInputStreamTask.getCheckpointBarrierHandler() |
protected Optional<CheckpointBarrierHandler> |
StreamTask.getCheckpointBarrierHandler()
Acquires the optional
CheckpointBarrierHandler associated with this stream task. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.