blobexpansion create

--database-name DATABASE

Kafka bucket name containing the source topic.

--table-name TABLE

Source Kafka topic name.

--target-table-name TABLE

Target database table name for expanded data.

--arrow-schema ARROW_SCHEMA

Column definitions as a comma-separate list of name-type pairs. These are the fields (and their type) in the Kafka event source that are parsed. They are parsed into columns of the same name and type in the target table. Columns are created in the target database table if they do not already exist.

Example --arrow-schema id-int64,status-string,score-double

This selects fields id, status, and score, for parsing from event messages.

--tenant-id TENANT

Tenant ID (optional) for the schema.

--source-column-name COLUMN

Source column name (only 'value' is supported)

--target-table-schema TARGET_SCHEMA

Target table schema (optional)

--expansion-format EXPANSION_FORMAT

The format of the source column, that is expanded (only 'json' is supported)

--copy-source-column

If set, the raw source event message (in binary JSON format) is copied to the target table.

--flatten-path

Flatten nested JSON paths. If set, nested JSON paths are parsed as a flat path.

Example: this JSON block:

"user": {
    "profile": {
      "name": "Alice",
      "age": 30
    }
  }

is parsed to user_profile_name, user_profile_age (where the delimiter is '_').

--flatten-delimiter FLATTEN_DELIMITER

Delimiter for flattened paths (default: '__')