Class SnapshotObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.observer.SnapshotObserver<CR,STATUS>
-
public class SnapshotObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>> extends java.lang.Object
An observer of savepoint progress.
-
-
Constructor Summary
Constructors Constructor Description SnapshotObserver(EventRecorder eventRecorder)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
observeCheckpointStatus(FlinkResourceContext<CR> ctx)
void
observeSavepointStatus(FlinkResourceContext<CR> ctx)
-
-
-
Constructor Detail
-
SnapshotObserver
public SnapshotObserver(EventRecorder eventRecorder)
-
-
Method Detail
-
observeSavepointStatus
public void observeSavepointStatus(FlinkResourceContext<CR> ctx)
-
observeCheckpointStatus
public void observeCheckpointStatus(FlinkResourceContext<CR> ctx)
-
-