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

Class ReconciliationStatus<SPEC extends AbstractFlinkSpec>

java.lang.Object

org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus<SPEC>

Direct Known Subclasses:

FlinkDeploymentReconciliationStatus, FlinkSessionJobReconciliationStatus

@Experimental
public abstract class ReconciliationStatus<SPEC extends AbstractFlinkSpec>
extends java.lang.Object

Status of the last reconcile step for the FlinkDeployment/FlinkSessionJob.

Constructor Summary

Constructors

Constructor	Description
ReconciliationStatus()

Method Summary

Modifier and Type	Method	Description
SPEC	deserializeLastReconciledSpec()
SpecWithMeta<SPEC>	deserializeLastReconciledSpecWithMeta()
SPEC	deserializeLastStableSpec()
SpecWithMeta<SPEC>	deserializeLastStableSpecWithMeta()
abstract java.lang.Class<SPEC>	getSpecClass()
boolean	isBeforeFirstDeployment()
boolean	isLastReconciledSpecStable()
void	markReconciledSpecAsStable()
boolean	scalingInProgress()	Deprecated.
void	serializeAndSetLastReconciledSpec(SPEC spec, AbstractFlinkResource<SPEC,?> resource)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReconciliationStatus

public ReconciliationStatus()

Method Detail

getSpecClass

public abstract java.lang.Class<SPEC> getSpecClass()

deserializeLastReconciledSpec

public SPEC deserializeLastReconciledSpec()

deserializeLastStableSpec

public SPEC deserializeLastStableSpec()

deserializeLastReconciledSpecWithMeta

public SpecWithMeta<SPEC> deserializeLastReconciledSpecWithMeta()

deserializeLastStableSpecWithMeta

public SpecWithMeta<SPEC> deserializeLastStableSpecWithMeta()

serializeAndSetLastReconciledSpec

public void serializeAndSetLastReconciledSpec(SPEC spec,
                                              AbstractFlinkResource<SPEC,?> resource)

markReconciledSpecAsStable

public void markReconciledSpecAsStable()

isLastReconciledSpecStable

public boolean isLastReconciledSpecStable()

isBeforeFirstDeployment

public boolean isBeforeFirstDeployment()

scalingInProgress

@Deprecated
public boolean scalingInProgress()

Deprecated.

This method is only here for backward compatibility reasons. The current version of the operator does not leave the resources in UPGRADING state during in-place scaling therefore this method will always return false.

Returns:

True if in-place scaling is in progress.