A litte code cleanup

wgzhao · Dec 1, 2020 · 457d768 · 457d768
1 parent 0042f90
commit 457d768
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...va/com/alibaba/datax/plugin/unstructuredstorage/reader/UnstructuredStorageReaderUtil.java b/...va/com/alibaba/datax/plugin/unstructuredstorage/reader/UnstructuredStorageReaderUtil.java
@@ -5,6 +5,7 @@
 import com.alibaba.datax.common.element.DateColumn;
 import com.alibaba.datax.common.element.DoubleColumn;
 import com.alibaba.datax.common.element.LongColumn;
+import com.alibaba.datax.common.element.Record;
 import com.alibaba.datax.common.element.StringColumn;
 import com.alibaba.datax.common.exception.DataXException;
 import com.alibaba.datax.common.plugin.RecordSender;
@@ -372,11 +373,11 @@ public static com.alibaba.datax.common.element.Record transportOneRecord(RecordS
         return transportOneRecord(recordSender, column, sourceLine, nullFormat, taskPluginCollector);
     }
 
-    public static com.alibaba.datax.common.element.Record transportOneRecord(RecordSender recordSender,
+    public static Record transportOneRecord(RecordSender recordSender,
             List<ColumnEntry> columnConfigs, String[] sourceLine,
             String nullFormat, TaskPluginCollector taskPluginCollector)
     {
-        com.alibaba.datax.common.element.Record record = recordSender.createRecord();
+        Record record = recordSender.createRecord();
         Column columnGenerated;
 
         // 创建都为String类型column的record

diff --git a/streamreader/src/main/java/com/alibaba/datax/plugin/reader/streamreader/StreamReader.java b/streamreader/src/main/java/com/alibaba/datax/plugin/reader/streamreader/StreamReader.java
@@ -328,7 +328,6 @@ private Column buildOneColumn(Configuration eachColumnConfig)
                         return new DateColumn(new Date(RandomUtils.nextLong(param1Int, param2Int + 1)));
                     }
                     else {
-                        System.out.println(format.parse(columnValue));
                         return new DateColumn(format.parse(columnValue));
                     }
                 case BOOL: