wip

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/process/BigDataNode.java

@@ -34,6 +34,8 @@ public class BigDataNode extends AbstractNode implements IBigDataNode {
     protected String outputType = null;
 
     protected String inputType = null;
+    
+    protected String workingType;
 
     protected Map<String, List<IMetadataColumn>> keyList = new HashMap<String, List<IMetadataColumn>>();
 
@@ -361,4 +363,9 @@ public class BigDataNode extends AbstractNode implements IBigDataNode {
     public void processDatasetConditions(){
         // BigDataNode does not do anything related to Dataset, only anabled from SparkNode
     }
+    
+    @Override
+    public String getWorkingType(){
+    	return this.workingType;
+    }
 }

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/process/IBigDataNode.java

@@ -142,4 +142,6 @@ public interface IBigDataNode extends INode {
      */
     public void processDatasetConditions();
 
+	public String getWorkingType();
+
 }