Uses of Class
org.apache.flink.kubernetes.operator.api.AbstractFlinkResource
-
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api
Subclasses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api Modifier and Type Class Description class
FlinkDeployment
Custom resource definition that represents both Application and Session deployments.class
FlinkSessionJob
Custom resource definition that represents a flink session job. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api.listener
Classes in org.apache.flink.kubernetes.operator.api.listener with type parameters of type AbstractFlinkResource Modifier and Type Interface Description static interface
FlinkResourceListener.ResourceContext<R extends AbstractFlinkResource<?,?>>
Base for Resource Event and StatusUpdate contexts.static interface
FlinkResourceListener.ResourceEventContext<R extends AbstractFlinkResource<?,?>>
Context for Resource Event listener methods.static interface
FlinkResourceListener.StatusUpdateContext<R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>>
Context for Status listener methods. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api.reconciler
Methods in org.apache.flink.kubernetes.operator.api.reconciler with parameters of type AbstractFlinkResource Modifier and Type Method Description static ReconciliationMetadata
ReconciliationMetadata. from(AbstractFlinkResource<?,?> resource)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api.status
Methods in org.apache.flink.kubernetes.operator.api.status with parameters of type AbstractFlinkResource Modifier and Type Method Description void
ReconciliationStatus. serializeAndSetLastReconciledSpec(SPEC spec, AbstractFlinkResource<SPEC,?> resource)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.api.utils
Methods in org.apache.flink.kubernetes.operator.api.utils with parameters of type AbstractFlinkResource Modifier and Type Method Description static CheckpointInfo
FlinkResourceUtils. getCheckpointInfo(AbstractFlinkResource<?,?> deployment)
static JobSpec
FlinkResourceUtils. getJobSpec(AbstractFlinkResource<? extends AbstractFlinkSpec,? extends CommonStatus<?>> deployment)
static JobStatus
FlinkResourceUtils. getJobStatus(AbstractFlinkResource<?,?> deployment)
static JobSpec
FlinkResourceUtils. getReconciledJobSpec(AbstractFlinkResource<?,?> deployment)
static JobState
FlinkResourceUtils. getReconciledJobState(AbstractFlinkResource<?,?> deployment)
static SavepointInfo
FlinkResourceUtils. getSavepointInfo(AbstractFlinkResource<?,?> deployment)
static java.lang.String
SpecUtils. writeSpecWithMeta(AbstractFlinkSpec spec, AbstractFlinkResource<?,?> relatedResource)
Serializes the spec and custom meta information into a JSON string. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler that return AbstractFlinkResource Modifier and Type Method Description AbstractFlinkResource<?,?>
KubernetesJobAutoScalerContext. getResource()
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.controller
Classes in org.apache.flink.kubernetes.operator.controller with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
FlinkResourceContext<CR extends AbstractFlinkResource<?,?>>
Context for reconciling a Flink resource. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.health
Classes in org.apache.flink.kubernetes.operator.health with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
CanaryResourceManager<CR extends AbstractFlinkResource<?,?>>
Logic encapsulating canary tests. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.listener
Methods in org.apache.flink.kubernetes.operator.listener with type parameters of type AbstractFlinkResource Modifier and Type Method Description static <R extends AbstractFlinkResource<?,?>>
voidAuditUtils. logContext(FlinkResourceListener.ResourceEventContext<R> ctx)
static <R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>>
voidAuditUtils. logContext(FlinkResourceListener.StatusUpdateContext<R,S> ctx)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.metrics
Classes in org.apache.flink.kubernetes.operator.metrics with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
MetricManager<CR extends AbstractFlinkResource<?,?>>
Metric manager for Operator managed custom resources.Methods in org.apache.flink.kubernetes.operator.metrics with parameters of type AbstractFlinkResource Modifier and Type Method Description static KubernetesResourceMetricGroup
OperatorMetricUtils. createResourceMetricGroup(KubernetesOperatorMetricGroup operatorMetricGroup, FlinkConfigManager configManager, AbstractFlinkResource<?,?> resource)
Method parameters in org.apache.flink.kubernetes.operator.metrics with type arguments of type AbstractFlinkResource Modifier and Type Method Description KubernetesResourceNamespaceMetricGroup
KubernetesOperatorMetricGroup. createResourceNamespaceGroup(org.apache.flink.configuration.Configuration config, java.lang.Class<? extends AbstractFlinkResource> resourceClass, java.lang.String resourceNs)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.metrics.lifecycle
Classes in org.apache.flink.kubernetes.operator.metrics.lifecycle with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
LifecycleMetrics<CR extends AbstractFlinkResource<?,?>>
Utility for tracking resource lifecycle metrics globally and per namespace. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.observer
Classes in org.apache.flink.kubernetes.operator.observer with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
AbstractFlinkResourceObserver<CR extends AbstractFlinkResource<?,?>>
Base observer for all Flink resources.class
JobStatusObserver<R extends AbstractFlinkResource<?,?>>
An observer to observe the job status.interface
Observer<CR extends AbstractFlinkResource<?,?>>
The Observer of custom resource.class
SnapshotObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>
An observer of savepoint progress. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.reconciler
Classes in org.apache.flink.kubernetes.operator.reconciler with type parameters of type AbstractFlinkResource Modifier and Type Interface Description interface
Reconciler<CR extends AbstractFlinkResource<?,?>>
The interface of reconciler.Methods in org.apache.flink.kubernetes.operator.reconciler with type parameters of type AbstractFlinkResource Modifier and Type Method Description static <STATUS extends CommonStatus<?>,R extends AbstractFlinkResource<?,STATUS>>
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<R>ReconciliationUtils. toErrorStatusUpdateControl(FlinkResourceContext<R> ctx, java.lang.Exception e, StatusRecorder<R,STATUS> statusRecorder)
Update the resource error status and metrics when the operator encountered an exception during reconciliation.Methods in org.apache.flink.kubernetes.operator.reconciler with parameters of type AbstractFlinkResource Modifier and Type Method Description static void
ReconciliationUtils. clearLastReconciledSpecIfFirstDeploy(AbstractFlinkResource<?,?> resource)
Clear last reconciled spec if that corresponds to the first deployment.static <SPEC extends AbstractFlinkSpec>
SPECReconciliationUtils. getDeployedSpec(AbstractFlinkResource<SPEC,?> deployment)
static java.lang.Long
ReconciliationUtils. getUpgradeTargetGeneration(AbstractFlinkResource<?,?> resource)
Get spec generation for the current in progress upgrade.static boolean
ReconciliationUtils. isUpgradeModeChangedToLastStateAndHADisabledPreviously(AbstractFlinkResource<?,?> flinkApp, org.apache.flink.configuration.Configuration observeConfig)
static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateLastReconciledSnapshotTriggerNonce(SnapshotInfo snapshotInfo, AbstractFlinkResource<SPEC,?> target, SnapshotType snapshotType)
static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateReconciliationMetadata(AbstractFlinkResource<SPEC,?> resource)
static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf)
static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf, java.time.Clock clock)
Update status before deployment attempt of a new resource spec.static void
ReconciliationUtils. updateStatusForAlreadyUpgraded(AbstractFlinkResource<?,?> resource)
Updates status in cases where a previously successful deployment wasn't recorded for any reason.static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusForDeployedSpec(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf)
static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusForDeployedSpec(AbstractFlinkResource<SPEC,?> target, org.apache.flink.configuration.Configuration conf, java.time.Clock clock)
Update status after successful deployment of a new resource spec.static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusForSpecReconciliation(AbstractFlinkResource<SPEC,?> target, JobState stateAfterReconcile, org.apache.flink.configuration.Configuration conf, boolean upgrading, java.time.Clock clock)
Method parameters in org.apache.flink.kubernetes.operator.reconciler with type arguments of type AbstractFlinkResource Modifier and Type Method Description static <SPEC extends AbstractFlinkSpec>
booleanReconciliationUtils. applyValidationErrorAndResetSpec(FlinkResourceContext<? extends AbstractFlinkResource<SPEC,?>> ctx, java.lang.String validationError)
In case of validation errors we need to (temporarily) reset the old spec so that we can reconcile other outstanding changes, instead of simply blocking. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.reconciler.deployment
Classes in org.apache.flink.kubernetes.operator.reconciler.deployment with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>
Base class for all Flink resource reconcilers.class
AbstractJobReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>
Reconciler responsible for handling the job lifecycle according to the desired and current states. -
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service with type parameters of type AbstractFlinkResource Modifier and Type Method Description <CR extends AbstractFlinkResource<?,?>>
voidFlinkResourceContextFactory. cleanup(CR flinkApp)
<CR extends AbstractFlinkResource<?,?>>
FlinkResourceContext<CR>FlinkResourceContextFactory. getResourceContext(CR resource, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
Methods in org.apache.flink.kubernetes.operator.service with parameters of type AbstractFlinkResource Modifier and Type Method Description protected java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements>
NativeFlinkService. getVertexResources(org.apache.flink.client.program.rest.RestClusterClient<java.lang.String> client, AbstractFlinkResource<?,?> resource)
protected void
NativeFlinkService. updateVertexResources(org.apache.flink.client.program.rest.RestClusterClient<java.lang.String> client, AbstractFlinkResource<?,?> resource, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements> newReqs)
-
Uses of AbstractFlinkResource in org.apache.flink.kubernetes.operator.utils
Classes in org.apache.flink.kubernetes.operator.utils with type parameters of type AbstractFlinkResource Modifier and Type Class Description class
StatusRecorder<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>
Helper class for status management and updates.Methods in org.apache.flink.kubernetes.operator.utils with type parameters of type AbstractFlinkResource Modifier and Type Method Description static <S extends CommonStatus<?>,CR extends AbstractFlinkResource<?,S>>
StatusRecorder<CR,S>StatusRecorder. create(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, MetricManager<CR> metricManager, java.util.Collection<FlinkResourceListener> listeners)
static <R extends AbstractFlinkResource>
voidFlinkResourceExceptionUtils. updateFlinkResourceException(java.lang.Throwable throwable, R resource, FlinkOperatorConfiguration conf)
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type AbstractFlinkResource Modifier and Type Method Description static SnapshotStatus
SnapshotUtils. getLastSnapshotStatus(AbstractFlinkResource<?,?> resource, SnapshotType snapshotType)
static void
SnapshotUtils. resetSnapshotTriggers(AbstractFlinkResource<?,?> resource, EventRecorder eventRecorder, io.fabric8.kubernetes.client.KubernetesClient client)
protected static java.util.Optional<SnapshotTriggerType>
SnapshotUtils. shouldTriggerSnapshot(AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf, SnapshotType snapshotType)
Checks whether a snapshot should be triggered based on the current status and spec, and if yes, returns the correctSnapshotTriggerType
.boolean
EventRecorder. triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component, io.fabric8.kubernetes.client.KubernetesClient client)
boolean
EventRecorder. triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component, java.lang.String messageKey, io.fabric8.kubernetes.client.KubernetesClient client)
boolean
EventRecorder. triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, EventRecorder.Reason reason, java.lang.String message, EventRecorder.Component component, java.lang.String messageKey, io.fabric8.kubernetes.client.KubernetesClient client)
boolean
EventRecorder. triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, EventRecorder.Reason reason, EventRecorder.Component component, java.lang.String message, io.fabric8.kubernetes.client.KubernetesClient client)
boolean
EventRecorder. triggerEventOnce(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component, java.lang.String messageKey, io.fabric8.kubernetes.client.KubernetesClient client)
boolean
EventRecorder. triggerEventOnce(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, EventRecorder.Reason reason, java.lang.String message, EventRecorder.Component component, java.lang.String messageKey, io.fabric8.kubernetes.client.KubernetesClient client)
boolean
EventRecorder. triggerEventWithInterval(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component, java.lang.String messageKey, io.fabric8.kubernetes.client.KubernetesClient client, java.time.Duration interval)
boolean
EventRecorder. triggerEventWithLabels(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component, java.lang.String messageKey, io.fabric8.kubernetes.client.KubernetesClient client, java.time.Duration interval, java.util.function.Predicate<java.util.Map<java.lang.String,java.lang.String>> dedupePredicate, java.util.Map<java.lang.String,java.lang.String> labels)
static boolean
SnapshotUtils. triggerSnapshotIfNeeded(FlinkService flinkService, AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf, SnapshotType snapshotType)
Triggers any pending manual or periodic snapshots and updates the status accordingly.Constructor parameters in org.apache.flink.kubernetes.operator.utils with type arguments of type AbstractFlinkResource Constructor Description EventRecorder(java.util.function.BiConsumer<AbstractFlinkResource<?,?>,io.fabric8.kubernetes.api.model.Event> eventListener)
-