[samza] branch master updated: SAMZA-2482: Add app.main.class and app.main.args in ApplicationConfig (#1308)

[xinyu]

This is an automated email from the ASF dual-hosted git repository.

xinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 896cfee  SAMZA-2482: Add app.main.class and app.main.args in 
ApplicationConfig (#1308)
896cfee is described below

commit 896cfee840dbf111245095946e4504232e97d1fe
Author: Ke Wu <ke.wu...@icloud.com>
AuthorDate: Mon Mar 9 17:25:47 2020 -0700

    SAMZA-2482: Add app.main.class and app.main.args in ApplicationConfig 
(#1308)
---
 .../main/java/org/apache/samza/config/ApplicationConfig.java  | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git 
a/samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java 
b/samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java
index 3923f7b..0854c04 100644
--- a/samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java
+++ b/samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java
@@ -18,6 +18,7 @@
  */
 package org.apache.samza.config;
 
+import java.util.Optional;
 import org.apache.samza.runtime.UUIDGenerator;
 
 
@@ -56,6 +57,8 @@ public class ApplicationConfig extends MapConfig {
   public static final String APP_CLASS = "app.class";
   public static final String APP_MODE = "app.mode";
   public static final String APP_RUN_ID = "app.run.id";
+  public static final String APP_MAIN_CLASS = "app.main.class";
+  public static final String APP_MAIN_ARGS = "app.main.args";
 
   public ApplicationConfig(Config config) {
     super(config);
@@ -97,4 +100,12 @@ public class ApplicationConfig extends MapConfig {
     return ApplicationMode.valueOf(get(APP_MODE, 
ApplicationMode.STREAM.name()).toUpperCase());
   }
 
+  public Optional<String> getAppMainArgs() {
+    return Optional.ofNullable(get(APP_MAIN_CLASS));
+  }
+
+  public Optional<String> getAppMainClass() {
+    return Optional.ofNullable(get(APP_MAIN_ARGS));
+  }
+
 }