public class CheckpointsBroker extends Object
Checkpoints
from the head operator to the tail operator so that the tail
operator could decrease the reference count of the raw state when checkpoints are aborted. We
could not count on the head operator since it would be blocked on closing the raw state when
aborting the checkpoint. It also looks like a bug.Constructor and Description |
---|
CheckpointsBroker() |
Modifier and Type | Method and Description |
---|---|
static CheckpointsBroker |
get() |
<V> Checkpoints<V> |
getCheckpoints(org.apache.flink.statefun.flink.core.feedback.SubtaskFeedbackKey<V> key) |
<V> void |
setCheckpoints(org.apache.flink.statefun.flink.core.feedback.SubtaskFeedbackKey<V> key,
Checkpoints<V> checkpoints) |
public static CheckpointsBroker get()
public <V> void setCheckpoints(org.apache.flink.statefun.flink.core.feedback.SubtaskFeedbackKey<V> key, Checkpoints<V> checkpoints)
public <V> Checkpoints<V> getCheckpoints(org.apache.flink.statefun.flink.core.feedback.SubtaskFeedbackKey<V> key)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.