destinations.impl.clickhouse.clickhouse_adapter

clickhouse_adapter

def clickhouse_adapter(data: Any,
                       table_engine_type: TTableEngineType = None
                       ) -> DltResource

[view_source]

Prepares data for the ClickHouse destination by specifying which table engine type that should be used.

Arguments:

• data Any - The data to be transformed. It can be raw data or an instance of DltResource. If raw data, the function wraps it into a DltResource object.
• table_engine_type TTableEngineType, optional - The table index type used when creating the Synapse table.

Returns:

• DltResource - A resource with applied Synapse-specific hints.

Raises:

• ValueError - If input for table_engine_type is invalid.

Examples:

    data = [{"name": "Alice", "description": "Software Developer"}]
    clickhouse_adapter(data, table_engine_type="merge_tree")

[DltResource with hints applied]