thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

First working test

Browse Source
This commit is contained in:
alesapin 2020-09-21 17:47:10 +03:00
parent 4debccb7fe
commit 8517dda807
4 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Compression/CompressionCodecT64.cpp
View File

@ -683,7 +683,7 @@ void registerCodecT64(CompressionCodecFactory & factory)
auto type_idx = typeIdx(type);
if (type && type_idx == TypeIndex::Nothing)
throw Exception("T64 codec is not supported for specified type", ErrorCodes::ILLEGAL_SYNTAX_FOR_CODEC_TYPE);
throw Exception("T64 codec is not supported for specified type " + type->getName(), ErrorCodes::ILLEGAL_SYNTAX_FOR_CODEC_TYPE);
return std::make_shared<CompressionCodecT64>(type_idx, variant);
};

2
src/Storages/MergeTree/MergeTreeDataPartWriterWide.cpp
View File

@ -52,7 +52,7 @@ void MergeTreeDataPartWriterWide::addStreams(
}
else
{
compression_codec = CompressionCodecFactory::instance().get(effective_codec_desc, nullptr, default_codec, false);
compression_codec = CompressionCodecFactory::instance().get(effective_codec_desc, nullptr, default_codec, true);
}
if (compression_codec == nullptr)

1
tests/queries/0_stateless/01504_compression_multiple_streams.reference Normal file
View File

@ -0,0 +1 @@
1 1 [[1]] (1,[1])

18
tests/queries/0_stateless/01504_compression_multiple_streams.sql Normal file
View File

@ -0,0 +1,18 @@
DROP TABLE IF EXISTS columns_with_multiple_streams;
CREATE TABLE columns_with_multiple_streams (
field0 Nullable(Int64) CODEC(Delta(2), LZ4),
field1 Nullable(Int64) CODEC(Delta, LZ4),
field2 Array(Array(Int64)) CODEC(Delta, LZ4),
filed3 Tuple(UInt32, Array(UInt64)) CODEC(T64, Default)
)
ENGINE = MergeTree
ORDER BY tuple()
SETTINGS min_rows_for_wide_part = 0, min_bytes_for_wide_part = 0;
INSERT INTO columns_with_multiple_streams VALUES(1, 1, [[1]], tuple(1, [1]));
SELECT * FROM columns_with_multiple_streams;
DROP TABLE IF EXISTS columns_with_multiple_streams;