Uses of Class
org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext
-
-
Uses of KubernetesJobAutoScalerContext in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler that return types with arguments of type KubernetesJobAutoScalerContext Modifier and Type Method Description static JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>
AutoscalerFactory. create(io.fabric8.kubernetes.client.KubernetesClient client, EventRecorder eventRecorder, ClusterResourceManager clusterResourceManager)
Methods in org.apache.flink.kubernetes.operator.autoscaler with parameters of type KubernetesJobAutoScalerContext Modifier and Type Method Description void
KubernetesAutoScalerEventHandler. handleEvent(KubernetesJobAutoScalerContext context, AutoScalerEventHandler.Type type, java.lang.String reason, java.lang.String message, java.lang.String messageKey, java.time.Duration interval)
void
KubernetesAutoScalerEventHandler. handleScalingEvent(KubernetesJobAutoScalerContext context, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, java.lang.String message, java.time.Duration interval)
void
KubernetesScalingRealizer. realizeConfigOverrides(KubernetesJobAutoScalerContext context, ConfigChanges configChanges)
void
KubernetesScalingRealizer. realizeParallelismOverrides(KubernetesJobAutoScalerContext context, java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)
-
Uses of KubernetesJobAutoScalerContext in org.apache.flink.kubernetes.operator.autoscaler.state
Methods in org.apache.flink.kubernetes.operator.autoscaler.state with parameters of type KubernetesJobAutoScalerContext Modifier and Type Method Description void
ConfigMapStore. clearAll(KubernetesJobAutoScalerContext jobContext)
void
KubernetesAutoScalerStateStore. clearAll(KubernetesJobAutoScalerContext jobContext)
void
ConfigMapStore. flush(KubernetesJobAutoScalerContext jobContext)
void
KubernetesAutoScalerStateStore. flush(KubernetesJobAutoScalerContext jobContext)
java.util.SortedMap<java.time.Instant,CollectedMetrics>
KubernetesAutoScalerStateStore. getCollectedMetrics(KubernetesJobAutoScalerContext jobContext)
ConfigChanges
KubernetesAutoScalerStateStore. getConfigChanges(KubernetesJobAutoScalerContext jobContext)
java.util.Map<java.lang.String,java.lang.String>
KubernetesAutoScalerStateStore. getParallelismOverrides(KubernetesJobAutoScalerContext jobContext)
java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,ScalingSummary>>
KubernetesAutoScalerStateStore. getScalingHistory(KubernetesJobAutoScalerContext jobContext)
ScalingTracking
KubernetesAutoScalerStateStore. getScalingTracking(KubernetesJobAutoScalerContext jobContext)
protected java.util.Optional<java.lang.String>
ConfigMapStore. getSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key)
protected void
ConfigMapStore. putSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key, java.lang.String value)
void
KubernetesAutoScalerStateStore. removeCollectedMetrics(KubernetesJobAutoScalerContext jobContext)
void
KubernetesAutoScalerStateStore. removeConfigChanges(KubernetesJobAutoScalerContext jobContext)
void
KubernetesAutoScalerStateStore. removeParallelismOverrides(KubernetesJobAutoScalerContext jobContext)
void
KubernetesAutoScalerStateStore. removeScalingHistory(KubernetesJobAutoScalerContext jobContext)
protected void
ConfigMapStore. removeSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key)
void
KubernetesAutoScalerStateStore. storeCollectedMetrics(KubernetesJobAutoScalerContext jobContext, java.util.SortedMap<java.time.Instant,CollectedMetrics> metrics)
void
KubernetesAutoScalerStateStore. storeConfigChanges(KubernetesJobAutoScalerContext jobContext, ConfigChanges overrides)
void
KubernetesAutoScalerStateStore. storeParallelismOverrides(KubernetesJobAutoScalerContext jobContext, java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)
void
KubernetesAutoScalerStateStore. storeScalingHistory(KubernetesJobAutoScalerContext jobContext, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,ScalingSummary>> scalingHistory)
void
KubernetesAutoScalerStateStore. storeScalingTracking(KubernetesJobAutoScalerContext jobContext, ScalingTracking scalingTrack)
protected void
KubernetesAutoScalerStateStore. trimHistoryToMaxCmSize(KubernetesJobAutoScalerContext context)
-
Uses of KubernetesJobAutoScalerContext in org.apache.flink.kubernetes.operator.controller
Methods in org.apache.flink.kubernetes.operator.controller that return KubernetesJobAutoScalerContext Modifier and Type Method Description KubernetesJobAutoScalerContext
FlinkResourceContext. getJobAutoScalerContext()
-
Uses of KubernetesJobAutoScalerContext in org.apache.flink.kubernetes.operator.reconciler.deployment
Fields in org.apache.flink.kubernetes.operator.reconciler.deployment with type parameters of type KubernetesJobAutoScalerContext Modifier and Type Field Description protected JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>
AbstractFlinkResourceReconciler. autoscaler
-
Uses of KubernetesJobAutoScalerContext in org.apache.flink.kubernetes.operator.reconciler.sessionjob
Constructor parameters in org.apache.flink.kubernetes.operator.reconciler.sessionjob with type arguments of type KubernetesJobAutoScalerContext Constructor Description SessionJobReconciler(EventRecorder eventRecorder, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
-