From 065db72593172bfe23aa2f48877ca0f7cc5feb7d Mon Sep 17 00:00:00 2001
From: zhanghongqing <zhanghongqing@zdjizhi.com>
Date: Tue, 23 Aug 2022 18:16:45 +0800
Subject: 代码优化，优化clickhousesink写入
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/zdjizhi/etl/CKBatchWindow.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

(limited to 'src/main/java/com/zdjizhi/etl/CKBatchWindow.java')

diff --git a/src/main/java/com/zdjizhi/etl/CKBatchWindow.java b/src/main/java/com/zdjizhi/etl/CKBatchWindow.java
index f66455f..947bad8 100644
--- a/src/main/java/com/zdjizhi/etl/CKBatchWindow.java
+++ b/src/main/java/com/zdjizhi/etl/CKBatchWindow.java
@@ -16,8 +16,7 @@ public class CKBatchWindow implements AllWindowFunction<Map<String, Object>, Lis
         Iterator<Map<String, Object>> iterator = iterable.iterator();
         List<Map<String, Object>> batchLog = new ArrayList<>();
         while (iterator.hasNext()) {
-            Map<String, Object> next = iterator.next();
-            batchLog.add(next);
+            batchLog.add(iterator.next());
         }
         out.collect(batchLog);
     }
-- 
cgit v1.2.3