Uses of Interface
org.apache.flink.kubernetes.operator.service.FlinkService
-
-
Uses of FlinkService in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler with parameters of type FlinkService Modifier and Type Method Description 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.CollectedMetrics
ScalingMetricCollector. updateMetrics(AbstractFlinkResource<?,?> cr, AutoScalerInfo scalingInformation, FlinkService flinkService, org.apache.flink.configuration.Configuration conf)
-
Uses of FlinkService in org.apache.flink.kubernetes.operator.controller
Methods in org.apache.flink.kubernetes.operator.controller that return FlinkService Modifier and Type Method Description abstract FlinkService
FlinkResourceContext. getFlinkService()
Get theFlinkService
implementation for the current resource.FlinkService
FlinkSessionJobContext. getFlinkService()
Constructors in org.apache.flink.kubernetes.operator.controller with parameters of type FlinkService Constructor Description FlinkDeploymentContext(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkService flinkService, FlinkConfigManager configManager)
-
Uses of FlinkService in org.apache.flink.kubernetes.operator.service
Classes in org.apache.flink.kubernetes.operator.service that implement FlinkService Modifier and Type Class Description class
AbstractFlinkService
An abstractFlinkService
containing some common implementations for the native and standalone Flink Services.class
NativeFlinkService
Implementation ofFlinkService
submitting and interacting with Native Kubernetes Flink clusters and jobs.class
StandaloneFlinkService
Implementation ofFlinkService
submitting and interacting with Standalone Kubernetes Flink clusters and jobs.Methods in org.apache.flink.kubernetes.operator.service that return FlinkService Modifier and Type Method Description protected FlinkService
FlinkResourceContextFactory. getOrCreateFlinkService(FlinkDeployment deployment)
-
Uses of FlinkService in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type FlinkService Modifier and Type Method Description 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.
-