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