You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2018/07/17 13:49:48 UTC
svn commit: r1836115 [4/4] - in /uima/uima-ducc/trunk: src/main/assembly/
uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/launcher/
uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/
uima-ducc-container/src/main/java/org/...
Added: uima/uima-ducc/trunk/uima-ducc-user/src/main/java/org/apache/uima/ducc/user/jp/uima/UimaAEContainer.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-user/src/main/java/org/apache/uima/ducc/user/jp/uima/UimaAEContainer.java?rev=1836115&view=auto
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-user/src/main/java/org/apache/uima/ducc/user/jp/uima/UimaAEContainer.java (added)
+++ uima/uima-ducc/trunk/uima-ducc-user/src/main/java/org/apache/uima/ducc/user/jp/uima/UimaAEContainer.java Tue Jul 17 13:49:47 2018
@@ -0,0 +1,47 @@
+package org.apache.uima.ducc.user.jp.uima;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.uima.UIMAFramework;
+import org.apache.uima.analysis_engine.AnalysisEngine;
+import org.apache.uima.ducc.user.common.UimaUtils;
+import org.apache.uima.resource.Resource;
+import org.apache.uima.resource.ResourceManager;
+import org.apache.uima.resource.ResourceSpecifier;
+import org.apache.uima.util.CasPool;
+import org.apache.uima.util.XMLInputSource;
+
+public class UimaAEContainer {
+ public static ResourceManager rm =
+ UIMAFramework.newDefaultResourceManager();
+ private CasPool casPool = null;
+ // Map to store DuccUimaSerializer instances. Each has affinity to a thread
+ private Map<Long, org.apache.uima.aae.UimaSerializer> serializerMap =
+ new HashMap<>();
+ // Platform MBean server if one is available (Java 1.5 only)
+ ThreadLocal<AnalysisEngine> threadLocal=null;
+ public UimaAEContainer( ThreadLocal<AnalysisEngine> threadLocal ) {
+ this.threadLocal = threadLocal;
+ }
+ public void initializeAe(String analysisEngineDescriptor, Object platformMBeanServer) throws Exception {
+ HashMap<String,Object> paramsMap = new HashMap<>();
+ paramsMap.put(Resource.PARAM_RESOURCE_MANAGER, rm);
+ paramsMap.put(AnalysisEngine.PARAM_MBEAN_SERVER, platformMBeanServer);
+
+ XMLInputSource is =
+ UimaUtils.getXMLInputSource(analysisEngineDescriptor);
+ String aed = is.getURL().toString();
+ ResourceSpecifier rSpecifier =
+ UimaUtils.getResourceSpecifier(aed);
+
+ AnalysisEngine ae = (AnalysisEngine)UIMAFramework.produceAnalysisEngine(rSpecifier,
+ paramsMap);
+ threadLocal.set(ae);
+
+// return UIMAFramework.produceAnalysisEngine(rSpecifier,
+// paramsMap);
+
+ }
+
+}