Skip to main content

Module clickhouse

Module clickhouse 

Source

StructsΒ§

ClickHouseCommon
ClickHouseConfig
ClickHouseSchemaFeature πŸ”’
ClickHouseSink
ClickHouseSinkWriter
ClickhouseQueryEngine πŸ”’
SystemColumn πŸ”’

EnumsΒ§

ClickHouseDecimal πŸ”’
ClickHouseEngine πŸ”’
ClickHouseField πŸ”’
Basic data types for use with the clickhouse interface
ClickHouseFieldWithNull πŸ”’
Enum that support clickhouse nullable

ConstantsΒ§

ALLOW_EXPERIMENTAL_JSON_TYPE πŸ”’
CLICKHOUSE_SINK
INPUT_FORMAT_BINARY_READ_JSON_AS_STRING πŸ”’
INSERT_CHUNK_SIZE πŸ”’
Encoded rows are sent once they reach this size, each send compressed as one block.
MAX_ENCODABLE_DECIMAL_PRECISION πŸ”’
ClickHouse backs Decimal(P, S) with Decimal256 once P > 38, which takes 32 bytes on the wire, while ClickHouseDecimal never writes more than 16.
OUTPUT_FORMAT_BINARY_WRITE_JSON_AS_STRING πŸ”’
QUERY_COLUMN πŸ”’
QUERY_ENGINE πŸ”’

FunctionsΒ§

build_fields_name_type_from_schema
β€˜Struct’(clickhouse type name is nested) will be converted into some arrays by clickhouse. So we need to make some conversions
contains_decimal πŸ”’
parse_decimal_accuracy πŸ”’
Parse (precision, scale) out of a decimal type, or None if it is not a decimal. system.columns renders decimals canonically, so Decimal128(10) arrives as Decimal(38, 10).
query_column_engine_from_ck πŸ”’