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