StarRocksDest

classView source ↗

class StarRocksDest(
    conn: StarRocksConn,
    destination_tables: str | list[str],
    if_table_exists: IfTableExistStrategySpec = 'append',
)

Bases: DestinationPlugin

Categories: destination

Destination plugin for writing data to StarRocks using cloud-staged bulk loading.

Data is first written as Parquet files to the configured cloud storage staging area (S3, Azure Blob, or GCS) and then ingested into StarRocks via its FILES() table function in an INSERT INTO … SELECT * FROM FILES(...) statement.

Initialize a StarRocksDest instance for writing data to StarRocks.

Parameters

parameter

conn

The StarRocks connection configuration, including both the server parameters and the cloud staging configuration.

parameter

destination_tables

The table(s) to load data into. A single table name may be provided as a string; multiple tables must be a list of strings.

parameter

if_table_exists

The strategy to follow when the table already exists. Defaults to 'append'. * 'append' — insert new rows into the existing table. * 'replace' — truncate the table before loading new rows.

Properties

property

connStarRocksConn

The StarRocks connection configuration.

property

destination_tableslist[str]

The table(s) to load data into.

property

if_table_existsIfTableExistStrategySpec

The strategy to follow when the table already exists.

Methods

method

View source ↗

stream

def stream(working_dir: str, *results: list[LazyFrame | None])

Write each result as a Parquet file and bulk load it into StarRocks via the cloud staging area.

Parameters:

parameter

working_dir

Temporary directory for intermediate Parquet files.

parameter

results

One polars LazyFrame (or None) per destination table, in the same order as destination_tables.