Package | Description |
---|---|
org.apache.flink.streaming.runtime.io.checkpointing |
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(AbstractInvokable 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) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.