0001811: Add new transform types that will put the source catalog, sc…

…hema or table names into a column
JumpMind · Jul 28, 2014 · 38e3af6 · 38e3af6
1 parent cbb749d
commit 38e3af6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/common/Constants.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/common/Constants.java
@@ -20,7 +20,8 @@
  */
 package org.jumpmind.symmetric.common;
 
-import org.jumpmind.symmetric.model.DataEvent;
+import org.jumpmind.symmetric.io.data.reader.ExtractDataReader;
+import org.jumpmind.symmetric.model.DataEvent;
 
 /**
  * General purpose constants used by SymmetricDS
@@ -42,7 +43,9 @@ private Constants() {
 
     public static final String DATA_CONTEXT_TARGET_NODE_GROUP_ID = "targetNodeGroupId";
 
-    public static final String DATA_CONTEXT_TARGET_NODE_EXTERNAL_ID = "targetNodeExternalId";
+    public static final String DATA_CONTEXT_TARGET_NODE_EXTERNAL_ID = "targetNodeExternalId";
+
+    public static final String DATA_CONTEXT_CURRENT_CSV_DATA = ExtractDataReader.DATA_CONTEXT_CURRENT_CSV_DATA; 
 
     public static final String DATA_CONTEXT_SOURCE_NODE = "sourceNode";
 

diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/reader/ExtractDataReader.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/reader/ExtractDataReader.java
@@ -45,9 +45,9 @@
 
 public class ExtractDataReader implements IDataReader {
 
-    protected static final Logger log = LoggerFactory.getLogger(ExtractDataReader.class);
+    protected static final Logger log = LoggerFactory.getLogger(ExtractDataReader.class);    
 
-    public static final String DATA_CONTEXT_CURRENT_CSV_DATA = CsvData.class.getName(); 
+    public static final String DATA_CONTEXT_CURRENT_CSV_DATA = "csvData"; 
 
     protected Map<Batch, Statistics> statistics = new HashMap<Batch, Statistics>();