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