thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-14 18:32:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Sergey Katkovskiy 2023-05-26 10:09:49 +03:00
parent 528fa9ae04
commit 3629e0c980
3 changed files with 1 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Storages/S3Queue/S3QueueSource.cpp
View File

@ -28,12 +28,6 @@
# include <Storages/VirtualColumnUtils.h> # include <Storages/VirtualColumnUtils.h>
# include <Storages/getVirtualsForStorage.h> # include <Storages/getVirtualsForStorage.h>
# include <Disks/IO/AsynchronousReadIndirectBufferFromRemoteFS.h>
# include <Disks/IO/ReadBufferFromRemoteFSGather.h>
# include <Disks/ObjectStorages/StoredObject.h>
# include <IO/ReadBufferFromS3.h>
# include <Formats/FormatFactory.h> # include <Formats/FormatFactory.h>
# include <Processors/Formats/IInputFormat.h> # include <Processors/Formats/IInputFormat.h>

6
src/Storages/S3Queue/StorageS3Queue.cpp
View File

@ -37,9 +37,6 @@
# include <Common/NamedCollections/NamedCollections.h> # include <Common/NamedCollections/NamedCollections.h>
# include <Disks/IO/AsynchronousReadIndirectBufferFromRemoteFS.h>
# include <Disks/IO/ReadBufferFromRemoteFSGather.h>
# include <Formats/FormatFactory.h> # include <Formats/FormatFactory.h>
# include <Processors/Formats/IInputFormat.h> # include <Processors/Formats/IInputFormat.h>
@ -93,7 +90,6 @@ StorageS3Queue::StorageS3Queue(
const String & comment, const String & comment,
ContextPtr context_, ContextPtr context_,
std::optional<FormatSettings> format_settings_, std::optional<FormatSettings> format_settings_,
bool distributed_processing_,
ASTPtr partition_by_) ASTPtr partition_by_)
: IStorage(table_id_) : IStorage(table_id_)
, WithContext(context_) , WithContext(context_)
@ -106,7 +102,6 @@ StorageS3Queue::StorageS3Queue(
, format_name(configuration_.format) , format_name(configuration_.format)
, compression_method(configuration_.compression_method) , compression_method(configuration_.compression_method)
, name(s3_configuration.url.storage_name) , name(s3_configuration.url.storage_name)
, distributed_processing(distributed_processing_)
, format_settings(format_settings_) , format_settings(format_settings_)
, partition_by(partition_by_) , partition_by(partition_by_)
, log(&Poco::Logger::get("StorageS3Queue (" + table_id_.table_name + ")")) , log(&Poco::Logger::get("StorageS3Queue (" + table_id_.table_name + ")"))
@ -709,7 +704,6 @@ void registerStorageS3QueueImpl(const String & name, StorageFactory & factory)
args.comment, args.comment,
args.getContext(), args.getContext(),
format_settings, format_settings,
/* distributed_processing_ */ false,
partition_by); partition_by);
}, },
{ {

3
src/Storages/S3Queue/StorageS3Queue.h
View File

@ -50,7 +50,6 @@ public:
const String & comment, const String & comment,
ContextPtr context_, ContextPtr context_,
std::optional<FormatSettings> format_settings_, std::optional<FormatSettings> format_settings_,
bool distributed_processing_ = false,
ASTPtr partition_by_ = nullptr); ASTPtr partition_by_ = nullptr);
String getName() const override { return "S3Queue"; } String getName() const override { return "S3Queue"; }
@ -92,7 +91,7 @@ private:
String format_name; String format_name;
String compression_method; String compression_method;
String name; String name;
const bool distributed_processing;
std::optional<FormatSettings> format_settings; std::optional<FormatSettings> format_settings;
ASTPtr partition_by; ASTPtr partition_by;