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

Class FlinkResourceUtils

java.lang.Object

org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils

public class FlinkResourceUtils
extends java.lang.Object

Utilities for Flink K8S resource.

Constructor Summary

Constructors

Constructor	Description
FlinkResourceUtils()

Method Summary

Modifier and Type	Method	Description
static CheckpointInfo	getCheckpointInfo(AbstractFlinkResource<?,?> deployment)
static JobSpec	getJobSpec(AbstractFlinkResource<? extends AbstractFlinkSpec,? extends CommonStatus<?>> deployment)
static JobStatus	getJobStatus(AbstractFlinkResource<?,?> deployment)
static JobSpec	getReconciledJobSpec(AbstractFlinkResource<?,?> deployment)
static JobState	getReconciledJobState(AbstractFlinkResource<?,?> deployment)
static SavepointInfo	getSavepointInfo(AbstractFlinkResource<?,?> deployment)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkResourceUtils

public FlinkResourceUtils()

Method Detail

getCheckpointInfo

public static CheckpointInfo getCheckpointInfo(AbstractFlinkResource<?,?> deployment)

getSavepointInfo

public static SavepointInfo getSavepointInfo(AbstractFlinkResource<?,?> deployment)

getJobStatus

public static JobStatus getJobStatus(AbstractFlinkResource<?,?> deployment)

getReconciledJobState

public static JobState getReconciledJobState(AbstractFlinkResource<?,?> deployment)

getReconciledJobSpec

public static JobSpec getReconciledJobSpec(AbstractFlinkResource<?,?> deployment)

getJobSpec

public static JobSpec getJobSpec(AbstractFlinkResource<? extends AbstractFlinkSpec,? extends CommonStatus<?>> deployment)