remove collectAsList call (#13)

Author: eemhu

src/main/java/com/teragrep/functions/dpf_02/BatchCollect.java

@@ -132,14 +132,13 @@ public void collect(Dataset<Row> batchDF, Long batchId, List<AbstractStep> postB
         if (!skipLimiting && limit > 0) {
             orderedDs = orderedDs.limit(limit);
         }
-        List<Row> collected = orderedDs.collectAsList();
-        Dataset<Row> createdDsFromCollected = SparkSession.builder().getOrCreate().createDataFrame(collected, this.inputSchema);
+
         Dataset<Row> current;
         if (this.savedDs == null) {
-            current = createdDsFromCollected;
+            current = orderedDs;
         }
         else {
-            current = savedDs.union(createdDsFromCollected);
+            current = savedDs.union(orderedDs);
         }
 
         current = orderDataset(current);