From 985a648fe6e28051acde9b99fcc09002bbc56463 Mon Sep 17 00:00:00 2001
From: Vxider <lb@vxider.com>
Date: Tue, 9 Jun 2020 23:58:27 +0800
Subject: [PATCH] code reuse

---
 src/Storages/WindowView/WatermarkBlockInputStream.h | 13 +++----------
 1 file changed, 3 insertions(+), 10 deletions(-)

diff --git a/src/Storages/WindowView/WatermarkBlockInputStream.h b/src/Storages/WindowView/WatermarkBlockInputStream.h
index e9c2f8da028..61638857462 100644
--- a/src/Storages/WindowView/WatermarkBlockInputStream.h
+++ b/src/Storages/WindowView/WatermarkBlockInputStream.h
@@ -16,17 +16,9 @@ public:
         BlockInputStreamPtr input_,
         StorageWindowView& storage_,
         String& window_column_name_)
-        : allowed_lateness(false)
-        , update_timestamp(false)
-        , watermark_specified(false)
-        , is_tumble(true)
-        , storage(storage_)
-        , window_column_name(window_column_name_)
-        , lateness_upper_bound(0)
-        , max_timestamp(0)
-        , max_watermark(0)
+        : WatermarkBlockInputStream(input_, storage_, window_column_name_, 0)
     {
-        children.push_back(input_);
+        watermark_specified = false;
     }
 
     WatermarkBlockInputStream(
@@ -43,6 +35,7 @@ public:
         , lateness_upper_bound(0)
         , max_timestamp(0)
         , max_watermark(max_watermark_)
+        , slice_num_units(0)
     {
         children.push_back(input_);
     }