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.dy.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