This command removes (drops) fields from being parsed from Kafka events. The column in the target database table remains, and any data in the column for messages parsed prior to it being dropped remains. Parsing of subsequent messages will not include the dropped fields.
Usage
vcli: admin> blobexpansion drop-columns --database-name DATABASE
--table-name TABLE
--arrow-schema ARROW_SCHEMA
[--tenant-id TENANT]
[--source-column-name SOURCE_COLUMN]
[--remove-copy-source-column REMOVE_COPY_SOURCE]
Required Parameters
| Kafka bucket name containing the source topic |
| Source Kafka topic name |
| Comma-separated list of fields of in the source of form name-type to discontinue parsing to the target, Example |
Options
| Tenant ID (optional) |
| Source column name (defaults to 'value') |
| If set, discontinues copying the source json blob to the target table. |
Example
This example shows the blobexpansion drop-columns command with sample values.
vcli: admin> blobexpansion drop-columns --tenant-id <integer> --database-name kafka_bucket --table-name my_topic --source-column-name value --arrow-schema col1-string,col2-int --remove-copy-source-column