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

Class SavepointObserver<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,STATUS>,STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<?>>

java.lang.Object

org.apache.flink.kubernetes.operator.observer.SavepointObserver<CR,STATUS>

public class SavepointObserver<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,STATUS>,STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<?>>
extends java.lang.Object

An observer of savepoint progress.

Constructor Summary

Constructors

Constructor	Description
SavepointObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
void	observeSavepointStatus(CR resource, org.apache.flink.configuration.Configuration deployedConfig)

Methods inherited from class java.lang.Object

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

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)