Uses of Class
org.apache.flink.autoscaler.topology.JobTopology
-
Packages that use JobTopology Package Description org.apache.flink.autoscaler org.apache.flink.autoscaler.metrics org.apache.flink.autoscaler.topology org.apache.flink.autoscaler.tuning -
-
Uses of JobTopology in org.apache.flink.autoscaler
Methods in org.apache.flink.autoscaler that return JobTopology Modifier and Type Method Description protected JobTopology
ScalingMetricCollector. getJobTopology(Context ctx, AutoScalerStateStore<KEY,Context> stateStore, JobDetailsInfo jobDetailsInfo)
protected JobTopology
ScalingMetricCollector. getJobTopology(JobDetailsInfo jobDetailsInfo)
Methods in org.apache.flink.autoscaler with parameters of type JobTopology Modifier and Type Method Description protected static double
ScalingMetricEvaluator. computeEdgeDataRate(JobTopology topology, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, org.apache.flink.runtime.jobgraph.JobVertexID from, org.apache.flink.runtime.jobgraph.JobVertexID to)
Compute how many records flow between two job vertices in the pipeline.protected static double
ScalingMetricEvaluator. computeEdgeOutputRatio(org.apache.flink.runtime.jobgraph.JobVertexID from, org.apache.flink.runtime.jobgraph.JobVertexID to, JobTopology topology, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory)
Compute the In/Out ratio between the (from, to) vertices.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(Context ctx, JobTopology topology)
Query the available metric names for each job vertex.boolean
ScalingTracking. recordRestartDurationIfTrackedAndParallelismMatches(java.time.Instant jobRunningTs, JobTopology jobTopology, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,ScalingSummary>> scalingHistory)
Sets restart duration for the latest scaling record if its parallelism matches the current job parallelism.boolean
ScalingExecutor. scaleResource(Context context, EvaluatedMetrics evaluatedMetrics, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,ScalingSummary>> scalingHistory, ScalingTracking scalingTracking, java.time.Instant now, JobTopology jobTopology)
protected boolean
ScalingExecutor. scalingWouldExceedMaxResources(org.apache.flink.configuration.Configuration tunedConfig, JobTopology jobTopology, EvaluatedMetrics evaluatedMetrics, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, Context ctx)
protected static boolean
ScalingExecutor. scalingWouldExceedResourceQuota(org.apache.flink.configuration.Configuration tunedConfig, JobTopology jobTopology, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, JobAutoScalerContext<?> ctx)
-
Uses of JobTopology in org.apache.flink.autoscaler.metrics
Methods in org.apache.flink.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, org.apache.flink.configuration.Configuration conf, java.util.function.Supplier<java.lang.Double> observedTprAvg)
-
Uses of JobTopology in org.apache.flink.autoscaler.topology
Methods in org.apache.flink.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,org.apache.flink.runtime.instance.SlotSharingGroupId> slotSharingGroupIdMap, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.lang.Integer> maxParallelismMap, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,IOMetrics> metrics, java.util.Set<org.apache.flink.runtime.jobgraph.JobVertexID> finishedVertices)
-
Uses of JobTopology in org.apache.flink.autoscaler.tuning
Methods in org.apache.flink.autoscaler.tuning with parameters of type JobTopology Modifier and Type Method Description static ConfigChanges
MemoryTuning. tuneTaskManagerMemory(JobAutoScalerContext<?> context, EvaluatedMetrics evaluatedMetrics, JobTopology jobTopology, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, AutoScalerEventHandler eventHandler)
Emits a Configuration which contains overrides for the current configuration.
-