public class HeadOperatorCoordinator extends Object implements org.apache.flink.runtime.operators.coordination.OperatorCoordinator, SharedProgressAlignerListener
HeadOperator
, it notifies the SharedProgressAligner
when received aligned event from the operator, and emit the globally
aligned event back after one round is globally aligned.Modifier and Type | Class and Description |
---|---|
static class |
HeadOperatorCoordinator.HeadOperatorCoordinatorProvider
The factory of
HeadOperatorCoordinator . |
org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.SubtaskGateway
Constructor and Description |
---|
HeadOperatorCoordinator(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context,
SharedProgressAligner sharedProgressAligner) |
Modifier and Type | Method and Description |
---|---|
void |
checkpointCoordinator(long l,
CompletableFuture<byte[]> completableFuture) |
void |
close() |
void |
executionAttemptFailed(int subtask,
int attemptNumber,
Throwable reason) |
void |
executionAttemptReady(int subtask,
int attemptNumber,
org.apache.flink.runtime.operators.coordination.OperatorCoordinator.SubtaskGateway gateway) |
void |
handleEventFromOperator(int subtask,
int attemptNumber,
org.apache.flink.runtime.operators.coordination.OperatorEvent event) |
void |
notifyCheckpointComplete(long l) |
void |
onAligned(GloballyAlignedEvent globallyAlignedEvent) |
void |
onCheckpointAligned(CoordinatorCheckpointEvent coordinatorCheckpointEvent) |
void |
resetToCheckpoint(long checkpointId,
byte[] bytes) |
void |
start() |
void |
subtaskReset(int i,
long l) |
public HeadOperatorCoordinator(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context, SharedProgressAligner sharedProgressAligner)
public void start()
start
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
public void resetToCheckpoint(long checkpointId, @Nullable byte[] bytes)
resetToCheckpoint
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
public void handleEventFromOperator(int subtask, int attemptNumber, org.apache.flink.runtime.operators.coordination.OperatorEvent event) throws Exception
handleEventFromOperator
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
Exception
public void checkpointCoordinator(long l, CompletableFuture<byte[]> completableFuture)
checkpointCoordinator
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
public void onAligned(GloballyAlignedEvent globallyAlignedEvent)
onAligned
in interface SharedProgressAlignerListener
public void onCheckpointAligned(CoordinatorCheckpointEvent coordinatorCheckpointEvent)
onCheckpointAligned
in interface SharedProgressAlignerListener
public void close()
close
in interface AutoCloseable
close
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
public void notifyCheckpointComplete(long l)
notifyCheckpointComplete
in interface org.apache.flink.api.common.state.CheckpointListener
notifyCheckpointComplete
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
public void subtaskReset(int i, long l)
subtaskReset
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
public void executionAttemptFailed(int subtask, int attemptNumber, @Nullable Throwable reason)
executionAttemptFailed
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
public void executionAttemptReady(int subtask, int attemptNumber, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.SubtaskGateway gateway)
executionAttemptReady
in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.