From eb634a60b91b3b6f18ca3bfddd9b98479b7afd89 Mon Sep 17 00:00:00 2001 From: lijianan Date: Thu, 11 Jan 2024 10:09:45 +0800 Subject: [PATCH] make file storage unsupport streaming query --- src/Storages/FileLog/StorageFileLog.h | 2 ++ src/Storages/StorageFile.h | 2 -- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Storages/FileLog/StorageFileLog.h b/src/Storages/FileLog/StorageFileLog.h index 582eec06a4b..32d344a986b 100644 --- a/src/Storages/FileLog/StorageFileLog.h +++ b/src/Storages/FileLog/StorageFileLog.h @@ -208,6 +208,8 @@ class StorageFileLog final : public shared_ptr_helper, public IS void deserialize(); static void checkOffsetIsValid(const String & full_name, UInt64 offset); + + bool supportsStreamingQuery() const override { return true; } }; } diff --git a/src/Storages/StorageFile.h b/src/Storages/StorageFile.h index 893b355cdb9..51efc09f70a 100644 --- a/src/Storages/StorageFile.h +++ b/src/Storages/StorageFile.h @@ -94,8 +94,6 @@ friend class PartitionedStorageFileSink; static SchemaCache & getSchemaCache(const ContextPtr & context); - bool supportsStreamingQuery() const override { return true; } - protected: friend class StorageFileSource; friend class StorageFileSink;