Adding support for streaming mode to JSONEachRowRowOutputFormat

src/Processors/Formats/Impl/JSONEachRowRowOutputFormat.cpp

@@ -22,6 +22,12 @@ JSONEachRowRowOutputFormat::JSONEachRowRowOutputFormat(WriteBuffer & out_, const
     }
 }
 
+void JSONEachRowRowOutputFormat::consume(DB::Chunk chunk)
+{
+    IRowOutputFormat::consume(std::move(chunk));
+    if (settings.enable_streaming)
+        flush();
+}
 
 void JSONEachRowRowOutputFormat::writeField(const IColumn & column, const IDataType & type, size_t row_num)
 {

src/Processors/Formats/Impl/JSONEachRowRowOutputFormat.h

@@ -25,6 +25,7 @@ public:
     void writeRowEndDelimiter() override;
 
 protected:
+    void consume(Chunk chunk) override;
     /// No totals and extremes.
     void consumeTotals(Chunk) override {}
     void consumeExtremes(Chunk) override {}