This commit is contained in:
Nikita Vasilev 2019-07-28 14:45:50 +03:00
parent 908623c029
commit 4c5003b3b9
6 changed files with 8 additions and 8 deletions

View File

@ -18,7 +18,7 @@ namespace
IMergedBlockOutputStream::IMergedBlockOutputStream(
MergeTreeData & storage_,
String part_path_,
const String & part_path_,
size_t min_compress_block_size_,
size_t max_compress_block_size_,
CompressionCodecPtr codec_,

View File

@ -16,7 +16,7 @@ class IMergedBlockOutputStream : public IBlockOutputStream
public:
IMergedBlockOutputStream(
MergeTreeData & storage_,
String part_path_,
const String & part_path_,
size_t min_compress_block_size_,
size_t max_compress_block_size_,
CompressionCodecPtr default_codec_,

View File

@ -21,7 +21,7 @@ namespace ErrorCodes
MergedBlockOutputStream::MergedBlockOutputStream(
MergeTreeData & storage_,
String part_path_,
const String & part_path_,
const NamesAndTypesList & columns_list_,
CompressionCodecPtr default_codec_,
bool blocks_are_granules_size_)
@ -44,7 +44,7 @@ MergedBlockOutputStream::MergedBlockOutputStream(
MergedBlockOutputStream::MergedBlockOutputStream(
MergeTreeData & storage_,
String part_path_,
const String & part_path_,
const NamesAndTypesList & columns_list_,
CompressionCodecPtr default_codec_,
const MergeTreeData::DataPart::ColumnToSize & merged_column_to_size_,

View File

@ -15,14 +15,14 @@ class MergedBlockOutputStream final : public IMergedBlockOutputStream
public:
MergedBlockOutputStream(
MergeTreeData & storage_,
String part_path_,
const String & part_path_,
const NamesAndTypesList & columns_list_,
CompressionCodecPtr default_codec_,
bool blocks_are_granules_size_ = false);
MergedBlockOutputStream(
MergeTreeData & storage_,
String part_path_,
const String & part_path_,
const NamesAndTypesList & columns_list_,
CompressionCodecPtr default_codec_,
const MergeTreeData::DataPart::ColumnToSize & merged_column_to_size_,

View File

@ -4,7 +4,7 @@ namespace DB
{
MergedColumnOnlyOutputStream::MergedColumnOnlyOutputStream(
MergeTreeData & storage_, const Block & header_, String part_path_, bool sync_,
MergeTreeData & storage_, const Block & header_, const String & part_path_, bool sync_,
CompressionCodecPtr default_codec_, bool skip_offsets_,
const std::vector<MergeTreeIndexPtr> & indices_to_recalc,
WrittenOffsetColumns & already_written_offset_columns,

View File

@ -13,7 +13,7 @@ public:
/// Pass empty 'already_written_offset_columns' first time then and pass the same object to subsequent instances of MergedColumnOnlyOutputStream
/// if you want to serialize elements of Nested data structure in different instances of MergedColumnOnlyOutputStream.
MergedColumnOnlyOutputStream(
MergeTreeData & storage_, const Block & header_, String part_path_, bool sync_,
MergeTreeData & storage_, const Block & header_, const String & part_path_, bool sync_,
CompressionCodecPtr default_codec_, bool skip_offsets_,
const std::vector<MergeTreeIndexPtr> & indices_to_recalc,
WrittenOffsetColumns & already_written_offset_columns,