This guide describes how to sink data from RisingWave to StarRocks.
struct
type.
Parameter names | Description |
---|---|
starrocks.host | The StarRocks host address. |
starrocks.query_port | The port to the MySQL server of the StarRocks frontend. |
starrocks.http_port | The port to the HTTP server of the StarRocks frontend. |
starrocks.user | The user name used to access the StarRocks database. |
starrocks.password | The password associated with the user. |
starrocks.database | The StarRocks database where the target table is located |
starrocks.table | The StarRocks table you want to sink data to. |
starrocks.partial_update | Optional. Set it to true to improve performance when you need to update many rows but only change a few columns in each row. |
type | Data format. Allowed formats:
|
force_append_only | If true , forces the sink to be append-only, even if it cannot be. |
primary_key | Required if type is upsert . The primary key of the downstream table. |
commit_checkpoint_interval | Optional. Commit every N checkpoints (N > 0). Default value is 10. The behavior of this field also depends on the sink_decouple setting:
|
bhv_mv
.
StarRocks type | RisingWave type |
---|---|
BOOLEAN | BOOLEAN |
SMALLINT | SMALLINT |
INT | INTEGER |
BIGINT | BIGINT |
FLOAT | REAL |
DOUBLE | DOUBLE |
DECIMAL | DECIMAL |
DATE | DATE |
VARCHAR | VARCHAR |
No support | TIME |
DATETIME | TIMESTAMP WITHOUT TIME ZONE |
No support | TIMESTAMP WITH TIME ZONE(Can be converted to timestamp in RisingWave then sinked into StarRocks ) |
No support | INTERVAL |
No support | STRUCT |
ARRAY | ARRAY |
No support | BYTEA |
JSON | JSONB |
BIGINT | SERIAL |
inf
, -inf
, or nan
, RisingWave will insert null values.