Package org.apache.flink.autoscaler
Interface JobAutoScaler<KEY,Context extends JobAutoScalerContext<KEY>>
-
- Type Parameters:
KEY
- The job key.Context
- Instance ofJobAutoScalerContext
.
- All Known Implementing Classes:
JobAutoScalerImpl
,NoopJobAutoscaler
@Internal public interface JobAutoScaler<KEY,Context extends JobAutoScalerContext<KEY>>
Flink Job AutoScaler.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cleanup(KEY jobKey)
Called when the job is deleted.void
scale(Context context)
Compute and apply new parallelism overrides for the provided job context.
-
-
-
Method Detail
-
scale
void scale(Context context) throws java.lang.Exception
Compute and apply new parallelism overrides for the provided job context.- Parameters:
context
- Job context.- Throws:
java.lang.Exception
-
cleanup
void cleanup(KEY jobKey)
Called when the job is deleted.- Parameters:
jobKey
- Job key.
-
-