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

T64 codec support for IPv4

Browse Source
This commit is contained in:
Yakov Olkhovskiy 2023-02-22 19:25:48 +00:00
parent 8e7533fa57
commit fadbeb8ebd
3 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Compression/CompressionCodecT64.cpp
View File

@ -88,6 +88,7 @@ enum class MagicNumber : uint8_t
Enum16 = 18, Enum16 = 18,
Decimal32 = 19, Decimal32 = 19,
Decimal64 = 20, Decimal64 = 20,
IPv4 = 21,
}; };
MagicNumber serializeTypeId(TypeIndex type_id) MagicNumber serializeTypeId(TypeIndex type_id)
@ -109,6 +110,7 @@ MagicNumber serializeTypeId(TypeIndex type_id)
case TypeIndex::Enum16: return MagicNumber::Enum16; case TypeIndex::Enum16: return MagicNumber::Enum16;
case TypeIndex::Decimal32: return MagicNumber::Decimal32; case TypeIndex::Decimal32: return MagicNumber::Decimal32;
case TypeIndex::Decimal64: return MagicNumber::Decimal64; case TypeIndex::Decimal64: return MagicNumber::Decimal64;
case TypeIndex::IPv4: return MagicNumber::IPv4;
default: default:
break; break;
} }
@ -136,6 +138,7 @@ TypeIndex deserializeTypeId(uint8_t serialized_type_id)
case MagicNumber::Enum16: return TypeIndex::Enum16; case MagicNumber::Enum16: return TypeIndex::Enum16;
case MagicNumber::Decimal32: return TypeIndex::Decimal32; case MagicNumber::Decimal32: return TypeIndex::Decimal32;
case MagicNumber::Decimal64: return TypeIndex::Decimal64; case MagicNumber::Decimal64: return TypeIndex::Decimal64;
case MagicNumber::IPv4: return TypeIndex::IPv4;
} }
throw Exception(ErrorCodes::LOGICAL_ERROR, "Bad magic number in T64 codec: {}", static_cast<UInt32>(serialized_type_id)); throw Exception(ErrorCodes::LOGICAL_ERROR, "Bad magic number in T64 codec: {}", static_cast<UInt32>(serialized_type_id));
@ -171,6 +174,7 @@ TypeIndex baseType(TypeIndex type_idx)
return TypeIndex::UInt16; return TypeIndex::UInt16;
case TypeIndex::UInt32: case TypeIndex::UInt32:
case TypeIndex::DateTime: case TypeIndex::DateTime:
case TypeIndex::IPv4:
return TypeIndex::UInt32; return TypeIndex::UInt32;
case TypeIndex::UInt64: case TypeIndex::UInt64:
return TypeIndex::UInt64; return TypeIndex::UInt64;
@ -198,6 +202,7 @@ TypeIndex typeIdx(const IDataType * data_type)
case TypeIndex::Date: case TypeIndex::Date:
case TypeIndex::Int32: case TypeIndex::Int32:
case TypeIndex::UInt32: case TypeIndex::UInt32:
case TypeIndex::IPv4:
case TypeIndex::DateTime: case TypeIndex::DateTime:
case TypeIndex::DateTime64: case TypeIndex::DateTime64:
case TypeIndex::Decimal32: case TypeIndex::Decimal32:

0
tests/queries/0_stateless/25338_ipv4_codec_t64.reference Normal file
View File

3
tests/queries/0_stateless/25338_ipv4_codec_t64.sql Normal file
View File

@ -0,0 +1,3 @@
DROP TABLE IF EXISTS ipv4_t64;
CREATE TABLE ipv4_t64 (uid Int16, ip IPv4 CODEC(T64), INDEX ip_idx ip TYPE bloom_filter GRANULARITY 4) ENGINE=MergeTree ORDER BY uid;
DROP TABLE IF EXISTS ipv4_t64;