StarRocksDestConn

class

class StarRocksDestConn(
    host: HostSpec,
    port: PortSpec = '9030',
    credentials: CredentialsSpec,
    staging: CloudLocation,
    database: DatabaseSpec = 'default',
    entity_whitelist: EntityWhitelistSpec | None = None,
    conn_cfg: CfgSpec | None = None,
)

Bases: Conn

Categories: destination

StarRocks connection.

Registered on a collection; the runtime resolves it and hands it to the plugin at run time. Each string field accepts a plain string or a Secret; the plugin reads parsed values through the _host / _port / _database getters.

Parameters

parameter

hostHostSpec (str | Secret)

A DNS host name or IPv4 literal for the StarRocks FE.

parameter

portPortSpec (str | Secret)

The MySQL-protocol port, 1-65535. Defaults to "9030".

parameter

credentialsCredentialsSpec (UserPassword)

UserPassword (user + password).

parameter

stagingCloudLocation

A CloudLocation (S3Location / AzBlobLocation / GCSLocation) where parquet is staged before ingest.

parameter

databaseDatabaseSpec (str | Secret)

The default database (a StarRocks identifier: a letter or underscore, then letters, digits and underscores). Defaults to "default".

parameter

entity_whitelistEntityWhitelistSpec | None (list[str] | None)

Optional list of regex patterns narrowing which tables the connector considers; None (the default) filters nothing.

parameter

conn_cfgCfgSpec | None (dict | None)

Optional connector-config dict (see CfgSpec).