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(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
observeSavepointStatus(CR resource, org.apache.flink.configuration.Configuration deployedConfig)
-
-
-
Constructor Detail
-
SavepointObserver
public SavepointObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
-
-
Method Detail
-
observeSavepointStatus
public void observeSavepointStatus(CR resource, org.apache.flink.configuration.Configuration deployedConfig)
-
-