You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2014/11/25 22:18:21 UTC
svn commit: r1641696 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/container/FlagsHelper.java
Author: degenaro
Date: Tue Nov 25 21:18:21 2014
New Revision: 1641696
URL: http://svn.apache.org/r1641696
Log:
UIMA-4069 Redesign of JD toward the main goal of classpath separation for container (system) code.
New flags and revised logic in FlagsHelper.
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/container/FlagsHelper.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/container/FlagsHelper.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/container/FlagsHelper.java?rev=1641696&r1=1641695&r2=1641696&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/container/FlagsHelper.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/container/FlagsHelper.java Tue Nov 25 21:18:21 2014
@@ -18,6 +18,8 @@
*/package org.apache.uima.ducc.common.container;
import java.io.File;
+import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Properties;
public class FlagsHelper {
@@ -30,26 +32,36 @@ public class FlagsHelper {
public enum Name {
- CollectionReaderCfg(false),
- CollectionReaderXml(true),
- JobId(true),
- UserClasspath(true),
- UserErrorHandlerClassname(false),
- UserErrorHandlerCfg(false),
+ CollectionReaderCfg,
+ CollectionReaderXml,
+ JdURL, // http://<node>:<port>/jdApp
+ JobId,
+ UserClasspath, // path1.class:path2.jar:path3/*:...
+ UserErrorHandlerClassname,
+ UserErrorHandlerCfg,
+ WorkItemTimeout, // maximum milliseconds that any work item should take to process
;
- private boolean requiredFlag;
+ private static ArrayList<Name> requiredJd = new ArrayList<Name>(Arrays.asList(CollectionReaderCfg, JobId, UserClasspath));
+ private static ArrayList<Name> requiredJp = new ArrayList<Name>(Arrays.asList(JdURL, JobId, UserClasspath));
- private Name(boolean requiredFlag) {
- setRequired(requiredFlag);
+ private Name() {
}
- private void setRequired(boolean value) {
- requiredFlag = value;
+ public boolean isRequiredJd() {
+ boolean retVal = false;
+ if(requiredJd.contains(this)) {
+ retVal = true;
+ }
+ return retVal;
}
- public boolean isRequired() {
- return requiredFlag;
+ public boolean isRequiredJp() {
+ boolean retVal = false;
+ if(requiredJp.contains(this)) {
+ retVal = true;
+ }
+ return retVal;
}
public String pname() {
@@ -90,6 +102,15 @@ public class FlagsHelper {
return Name.CollectionReaderXml.arg(value);
}
+ public String getJdURL() {
+ Properties properties = System.getProperties();
+ return properties.getProperty(Name.JdURL.pname());
+ }
+
+ public String getJdURLDashD(String value) {
+ return Name.JdURL.arg(value);
+ }
+
public String getJobId() {
Properties properties = System.getProperties();
return properties.getProperty(Name.JobId.pname());
@@ -126,6 +147,15 @@ public class FlagsHelper {
return Name.UserErrorHandlerCfg.arg(value);
}
+ public String getWorkItemTimeout() {
+ Properties properties = System.getProperties();
+ return properties.getProperty(Name.WorkItemTimeout.pname());
+ }
+
+ public String getWorkItemTimeoutDashD(String value) {
+ return Name.WorkItemTimeout.arg(value);
+ }
+
public String[] stringToArray(String classpath) {
String[] retVal = null;
if(classpath != null) {