Package org.apache.flink.kubernetes.operator.observer

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(FlinkConfigManager configManager, EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
void	observeSavepointStatus(FlinkResourceContext<CR> ctx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SavepointObserver

public SavepointObserver(FlinkConfigManager configManager,
                         EventRecorder eventRecorder)

Method Detail

observeSavepointStatus

public void observeSavepointStatus(FlinkResourceContext<CR> ctx)