Class FlinkSessionJob
- java.lang.Object
-
- io.fabric8.kubernetes.client.CustomResource<SPEC,STATUS>
-
- org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<FlinkSessionJobSpec,FlinkSessionJobStatus>
-
- org.apache.flink.kubernetes.operator.api.FlinkSessionJob
-
- All Implemented Interfaces:
io.fabric8.kubernetes.api.model.HasMetadata
,io.fabric8.kubernetes.api.model.KubernetesResource
,io.fabric8.kubernetes.api.model.Namespaced
,java.io.Serializable
@Experimental public class FlinkSessionJob extends AbstractFlinkResource<FlinkSessionJobSpec,FlinkSessionJobStatus> implements io.fabric8.kubernetes.api.model.Namespaced
Custom resource definition that represents a flink session job.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description FlinkSessionJob()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FlinkSessionJobSpec
initSpec()
protected FlinkSessionJobStatus
initStatus()
-
Methods inherited from class io.fabric8.kubernetes.client.CustomResource
equals, getApiVersion, getCRDName, getCRDName, getDeprecated, getDeprecationWarning, getDeprecationWarning, getGroup, getKind, getMetadata, getPlural, getPlural, getScope, getServed, getShortNames, getSingular, getSingular, getSpec, getStatus, getStorage, getVersion, hashCode, isDeprecated, isServed, isStorage, setApiVersion, setKind, setMetadata, setSpec, setStatus, toString
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface io.fabric8.kubernetes.api.model.HasMetadata
addFinalizer, addOwnerReference, addOwnerReference, getFinalizers, getFullResourceName, getOwnerReferenceFor, getOwnerReferenceFor, hasFinalizer, hasOwnerReferenceFor, hasOwnerReferenceFor, initNameAndNamespaceFrom, isFinalizerValid, isMarkedForDeletion, optionalMetadata, removeFinalizer, removeOwnerReference, removeOwnerReference
-
-
-
-
Method Detail
-
initStatus
protected FlinkSessionJobStatus initStatus()
- Overrides:
initStatus
in classio.fabric8.kubernetes.client.CustomResource<FlinkSessionJobSpec,FlinkSessionJobStatus>
-
initSpec
public FlinkSessionJobSpec initSpec()
- Overrides:
initSpec
in classio.fabric8.kubernetes.client.CustomResource<FlinkSessionJobSpec,FlinkSessionJobStatus>
-
-