Package org.apache.flink.kubernetes.operator.api.status

Class SavepointInfo

java.lang.Object

org.apache.flink.kubernetes.operator.api.status.SavepointInfo

@Experimental
public class SavepointInfo
extends java.lang.Object

Stores savepoint related information.

Constructor Summary

Constructors

Constructor	Description
SavepointInfo()

Method Summary

Modifier and Type	Method	Description
void	resetTrigger()
void	setTrigger(java.lang.String triggerId, SavepointTriggerType triggerType, SavepointFormatType formatType)
void	updateLastSavepoint(Savepoint savepoint)	Update last savepoint info and add the savepoint to the history if it isn't already the most recent savepoint.

Methods inherited from class java.lang.Object

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

Constructor Detail

SavepointInfo

public SavepointInfo()

Method Detail

setTrigger

public void setTrigger(java.lang.String triggerId,
                       SavepointTriggerType triggerType,
                       SavepointFormatType formatType)

resetTrigger

public void resetTrigger()

updateLastSavepoint

public void updateLastSavepoint(Savepoint savepoint)

Update last savepoint info and add the savepoint to the history if it isn't already the most recent savepoint.

Parameters:

savepoint - Savepoint to be added.