Compare commits

...

1 Commits

Author SHA1 Message Date
pyzhou-talend
1530cffb85 fix(TDI-40038):tRunjob performance 2018-02-28 15:08:59 +08:00
4 changed files with 17 additions and 1 deletions

View File

@@ -109,6 +109,9 @@
<PARAMETER NAME="TRANSMIT_ORIGINAL_CONTEXT" FIELD="CHECK" REQUIRED="true" SHOW="false" NUM_ROW="40">
<DEFAULT>true</DEFAULT>
</PARAMETER>
<PARAMETER NAME="CACHE_CHILD_JOB" FIELD="CHECK" REQUIRED="true" SHOW_IF="(USE_INDEPENDENT_PROCESS == 'false')" NUM_ROW="40">
<DEFAULT>true</DEFAULT>
</PARAMETER>
</ADVANCED_PARAMETERS>
<CODEGENERATION>

View File

@@ -382,8 +382,19 @@ String inputConnName = null;
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
if (!useIndependentProcess){//AAAAAAAAAAAA
boolean cacheChildJob = "true".equals(ElementParameterParser.getValue(node, "__CACHE_CHILD_JOB__"));
if(cacheChildJob){
%>
<%=childJob %> childJob_<%=cid %> = new <%=childJob %>();
<%=childJob %> childJob_<%=cid %> = null;
if (globalMap.get("childJob_<%=cid %>_SOPRASTERIA") != null) {
childJob_<%=cid %> = (<%=childJob %>) globalMap.get("childJob_<%=cid %>_SOPRASTERIA");
} else {
childJob_<%=cid %> = new <%=childJob %>();
globalMap.put("childJob_<%=cid %>_SOPRASTERIA", childJob_<%=cid %>);
}
<%} else {%>
<%=childJob %> childJob_<%=cid %> = new <%=childJob %>();
<%}%>
// pass DataSources
java.util.Map<String, routines.system.TalendDataSource> talendDataSources_<%=cid%> = (java.util.Map<String, routines.system.TalendDataSource>) globalMap
.get(KEY_DB_DATASOURCES);

View File

@@ -20,3 +20,4 @@ CHILD_EXCEPTION_STACKTRACE.NAME=Child exception stack trace
PROPAGATE_CHILD_RESULT.NAME=Propagate the child result to the output schema
PRINT_PARAMETER.NAME=Print Parameters
TRANSMIT_ORIGINAL_CONTEXT.NAME=Transmit original context value(if uncheck, there will convert context value to string type before transmiting.)
CACHE_CHILD_JOB.NAME=Cache Child Job

View File

@@ -17,3 +17,4 @@ USE_DYNAMIC_JOB.NAME=Use dynamic job
CONTEXT_JOB.NAME=Context job
CONTEXT_NAME.NAME=Context
PROPAGATE_CHILD_RESULT.NAME=Propagate the child result to the output schema
CACHE_CHILD_JOB.NAME=Cache Child Job