cassandra.write
Write into a Cassandra data store
Properties
| Name | Type | Description | Required |
|---|---|---|---|
| connection (The connection to use for loading) | string | Logical connection name as defined in the connections.yaml | yes |
| keyspace | string | Keyspace | yes |
| table (The target table name) | string | Target table name | yes |
| keys (Business keys) | array | yes | |
| mapping (Fields to write) | array | yes | |
| opcode_field | string | Name of the field in the payload that holds the operation (c - create, d - delete, u - update) for this record in the DB | yes |
Additional Properties: not allowed
Example
id: load_snowflake
type: relational.write
properties:
connection: eu_datalake
table: employees
schema: dbo
load_strategy: APPEND
keys[]: Business keys
Items: name of column
No properties.
Example
- fname
- lname: last_name
mapping[]: Fields to write
Items: name of column
No properties.
Example
- fname
- lname: last_name
- address
- gender