Interface AutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>>
-
- Type Parameters:
KEY
- The job key.Context
- Instance of JobAutoScalerContext.
- All Known Implementing Classes:
KubernetesAutoScalerEventHandler
,LoggingEventHandler
@Experimental public interface AutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>>
Handler for autoscaler events.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
AutoScalerEventHandler.Type
The type of the events.
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
SCALING_REPORT_KEY
static java.lang.String
SCALING_REPORT_REASON
static java.lang.String
SCALING_SUMMARY_ENTRY
static java.lang.String
SCALING_SUMMARY_HEADER_SCALING_DISABLED
static java.lang.String
SCALING_SUMMARY_HEADER_SCALING_ENABLED
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
handleEvent(Context context, AutoScalerEventHandler.Type type, java.lang.String reason, java.lang.String message, java.lang.String messageKey, java.time.Duration interval)
Handle the event.default void
handleScalingEvent(Context context, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, boolean scaled, java.time.Duration interval)
Handle scaling reports.static java.lang.String
scalingReport(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, boolean scalingEnabled)
-
-
-
Field Detail
-
SCALING_SUMMARY_ENTRY
static final java.lang.String SCALING_SUMMARY_ENTRY
- See Also:
- Constant Field Values
-
SCALING_SUMMARY_HEADER_SCALING_DISABLED
static final java.lang.String SCALING_SUMMARY_HEADER_SCALING_DISABLED
- See Also:
- Constant Field Values
-
SCALING_SUMMARY_HEADER_SCALING_ENABLED
static final java.lang.String SCALING_SUMMARY_HEADER_SCALING_ENABLED
- See Also:
- Constant Field Values
-
SCALING_REPORT_REASON
static final java.lang.String SCALING_REPORT_REASON
- See Also:
- Constant Field Values
-
SCALING_REPORT_KEY
static final java.lang.String SCALING_REPORT_KEY
- See Also:
- Constant Field Values
-
-
Method Detail
-
handleEvent
void handleEvent(Context context, AutoScalerEventHandler.Type type, java.lang.String reason, java.lang.String message, @Nullable java.lang.String messageKey, @Nullable java.time.Duration interval)
Handle the event.- Parameters:
interval
- Define the interval to suppress duplicate events. No dedupe if null.
-
handleScalingEvent
default void handleScalingEvent(Context context, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, boolean scaled, java.time.Duration interval)
Handle scaling reports.- Parameters:
interval
- Define the interval to suppress duplicate events.scaled
- Whether AutoScaler actually scaled the Flink job or just generate advice for scaling.
-
scalingReport
static java.lang.String scalingReport(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, boolean scalingEnabled)
-
-