Uses of Class
org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology
-
-
Uses of JobTopology in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler that return JobTopology Modifier and Type Method Description protected JobTopology
ScalingMetricCollector. getJobTopology(FlinkService flinkService, org.apache.flink.configuration.Configuration conf, AutoScalerInfo scalerInfo, org.apache.flink.runtime.rest.messages.job.JobDetailsInfo jobDetailsInfo)
protected JobTopology
ScalingMetricCollector. getJobTopology(org.apache.flink.runtime.rest.messages.job.JobDetailsInfo jobDetailsInfo)
Methods in org.apache.flink.kubernetes.operator.autoscaler with parameters of type JobTopology Modifier and Type Method Description protected java.util.Map<java.lang.String,FlinkMetric>
ScalingMetricCollector. getFilteredVertexMetricNames(org.apache.flink.client.program.rest.RestClusterClient<?> restClient, org.apache.flink.api.common.JobID jobID, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, JobTopology topology)
Query and filter metric names for a given job vertex.protected static boolean
ScalingMetricEvaluator. isProcessingBacklog(JobTopology topology, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, org.apache.flink.configuration.Configuration conf)
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. -
Uses of JobTopology in org.apache.flink.kubernetes.operator.autoscaler.metrics
Methods in org.apache.flink.kubernetes.operator.autoscaler.metrics with parameters of type JobTopology Modifier and Type Method Description static void
ScalingMetrics. computeDataRateMetrics(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics, java.util.Map<ScalingMetric,java.lang.Double> scalingMetrics, JobTopology topology, double lagGrowthRate, org.apache.flink.configuration.Configuration conf)
static java.util.Map<Edge,java.lang.Double>
ScalingMetrics. computeOutputRatios(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>> flinkMetrics, JobTopology topology)
-
Uses of JobTopology in org.apache.flink.kubernetes.operator.autoscaler.topology
Methods in org.apache.flink.kubernetes.operator.autoscaler.topology that return JobTopology Modifier and Type Method Description static JobTopology
JobTopology. fromJsonPlan(java.lang.String jsonPlan, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.lang.Integer> maxParallelismMap, java.util.Set<org.apache.flink.runtime.jobgraph.JobVertexID> finished)
-