thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 17:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Support reading from DirectoryMonitor.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-01-04 20:45:56 +03:00
parent 5869d6708b
commit 253c6cd59a
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
dbms/src/Storages/StorageFile.cpp
View File

@ -170,9 +170,6 @@ StorageFile::StorageFile(CommonArguments args)
: table_name(args.table_name), database_name(args.database_name), format_name(args.format_name)
, compression_method(args.compression_method), base_path(args.context.getPath())
{
setColumns(args.columns);
setConstraints(args.constraints);
if (args.format_name == "Distributed")
{
if (!paths.empty())
@ -183,6 +180,10 @@ StorageFile::StorageFile(CommonArguments args)
setColumns(ColumnsDescription(header.getNamesAndTypesList()));
}
}
else
setColumns(args.columns);
setConstraints(args.constraints);
}
class StorageFileBlockInputStream : public IBlockInputStream