rmatharu commented on a change in pull request #1266: Adding internal
autosizing related configs
URL: https://github.com/apache/samza/pull/1266#discussion_r374963426
##########
File path: samza-core/src/main/java/org/apache/samza/config/JobConfig.java
##########
@@ -310,6 +339,23 @@ public boolean getDiagnosticsEnabled() {
return getBoolean(JOB_DIAGNOSTICS_ENABLED, false);
}
+ public boolean getAutosizingEnabled() {
+ return getBoolean(JOB_AUTOSIZING_ENABLED, false);
+ }
+
+ public boolean isAutosizingConfig(String configParam) {
+ switch (configParam) {
+ case JOB_AUTOSIZING_CONTAINER_COUNT:
+ case JOB_AUTOSIZING_CONTAINER_MAX_CORES:
+ case JOB_AUTOSIZING_CONTAINER_MAX_HEAP_MB:
+ case JOB_AUTOSIZING_CONTAINER_MEMORY_MB:
+ case JOB_AUTOSIZING_CONTAINER_THREAD_POOL_SIZE:
Review comment:
Chose 3, and added comments and a config prefix variable.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
