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 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 with parameters of type AbstractFlinkResource Modifier and Type Method Description void
JobAutoScalerImpl. cleanup(AbstractFlinkResource<?,?> cr)
void
ScalingMetricCollector. cleanup(AbstractFlinkResource<?,?> cr)
int
JobVertexScaler. computeScaleTargetParallelism(AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf, org.apache.flink.runtime.jobgraph.JobVertexID vertex, java.util.Map<ScalingMetric,EvaluatedScalingMetric> evaluatedMetrics, java.util.SortedMap<java.time.Instant,ScalingSummary> history)
static AutoScalerInfo
AutoScalerInfo. forResource(AbstractFlinkResource<?,?> cr, io.fabric8.kubernetes.client.KubernetesClient kubeClient)
static long
ScalingMetricCollector. getDeployedGeneration(AbstractFlinkResource<?,?> cr)
protected JobTopology
ScalingMetricCollector. getJobTopology(FlinkService flinkService, AbstractFlinkResource<?,?> cr, org.apache.flink.configuration.Configuration conf, AutoScalerInfo scalerInfo)
protected java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>
RestApiMetricsCollector. queryAggregatedVertexMetrics(FlinkService flinkService, AbstractFlinkResource<?,?> cr, org.apache.flink.configuration.Configuration conf, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, java.util.Map<java.lang.String,FlinkMetric> metrics)
protected java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>>
RestApiMetricsCollector. queryAllAggregatedMetrics(AbstractFlinkResource<?,?> cr, FlinkService flinkService, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>> filteredVertexMetricNames)
protected abstract java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>>
ScalingMetricCollector. queryAllAggregatedMetrics(AbstractFlinkResource<?,?> cr, FlinkService flinkService, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>> filteredVertexMetricNames)
protected java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>>
ScalingMetricCollector. queryFilteredMetricNames(FlinkService flinkService, AbstractFlinkResource<?,?> cr, org.apache.flink.configuration.Configuration conf, JobTopology topology)
Query the available metric names for each job vertex for the current spec generation.boolean
ScalingExecutor. scaleResource(AbstractFlinkResource<?,?> resource, AutoScalerInfo scalingInformation, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> evaluatedMetrics)
CollectedMetrics
ScalingMetricCollector. updateMetrics(AbstractFlinkResource<?,?> cr, AutoScalerInfo scalingInformation, FlinkService flinkService, org.apache.flink.configuration.Configuration conf)
Method parameters in org.apache.flink.kubernetes.operator.autoscaler with type arguments of type AbstractFlinkResource Modifier and Type Method Description boolean
JobAutoScalerImpl. scale(FlinkResourceContext<? extends AbstractFlinkResource<?,?>> ctx)
-
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.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
SavepointObserver<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(R resource, java.util.Optional<io.javaoperatorsdk.operator.api.reconciler.RetryInfo> retryInfo, java.lang.Exception e, StatusRecorder<R,STATUS> statusRecorder, FlinkOperatorConfiguration operatorConfiguration)
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 <SPEC extends AbstractFlinkSpec>
booleanReconciliationUtils. applyValidationErrorAndResetSpec(AbstractFlinkResource<SPEC,?> deployment, java.lang.String validationError, FlinkOperatorConfiguration conf)
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.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 void
ReconciliationUtils. updateForReconciliationError(AbstractFlinkResource<?,?> target, java.lang.Throwable error, FlinkOperatorConfiguration conf)
static <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateLastReconciledSavepointTriggerNonce(SavepointInfo savepointInfo, AbstractFlinkResource<SPEC,?> target)
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 <SPEC extends AbstractFlinkSpec>
voidReconciliationUtils. updateStatusForAlreadyUpgraded(AbstractFlinkResource<SPEC,?> 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. -
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.Methods in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type AbstractFlinkResource Modifier and Type Method Description void
JobAutoScaler. cleanup(AbstractFlinkResource<?,?> cr)
Called when the custom resource is deleted.void
NoopJobAutoscalerFactory. cleanup(AbstractFlinkResource<?,?> cr)
Method parameters in org.apache.flink.kubernetes.operator.reconciler.deployment with type arguments of type AbstractFlinkResource Modifier and Type Method Description boolean
JobAutoScaler. scale(FlinkResourceContext<? extends AbstractFlinkResource<?,?>> ctx)
Called as part of the reconciliation loop. -
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<?,?>>
FlinkResourceContext<CR>FlinkResourceContextFactory. getResourceContext(CR resource, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
-
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 <T extends AbstractFlinkResource<?,?>>
voidKubernetesClientUtils. applyToStoredCr(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, T cr, java.util.function.Consumer<T> function)
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 SavepointStatus
SavepointUtils. getLastSavepointStatus(AbstractFlinkResource<?,?> resource)
static void
SavepointUtils. resetTriggerIfJobNotRunning(AbstractFlinkResource<?,?> resource, EventRecorder eventRecorder)
protected static java.util.Optional<SavepointTriggerType>
SavepointUtils. shouldTriggerSavepoint(AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf)
Checks whether savepoint should be triggered based on the current status and spec and if yes, returns the correctSavepointTriggerType
.boolean
EventRecorder. triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component)
boolean
EventRecorder. triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, EventRecorder.Reason reason, EventRecorder.Component component, java.lang.String message)
static boolean
SavepointUtils. triggerSavepointIfNeeded(FlinkService flinkService, AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf)
Triggers any pending manual or periodic savepoints and updates the status accordingly.Constructor parameters in org.apache.flink.kubernetes.operator.utils with type arguments of type AbstractFlinkResource Constructor Description EventRecorder(io.fabric8.kubernetes.client.KubernetesClient client, java.util.function.BiConsumer<AbstractFlinkResource<?,?>,io.fabric8.kubernetes.api.model.Event> eventListener)
-