cassandra.write
写入 Cassandra 数据存储
写入 Cassandra 数据存储
性能
| 名字 | 类型 | 描述 | 必填 |
|---|---|---|---|
| connection （用于加载的连接） |
string |
connections.yaml 中定义的逻辑连接名称 |
是的 |
| 键空间 | string |
键空间 |
是的 |
| table （目标表名） |
string |
目标表名称 |
是的 |
| keys （业务密钥） |
array |
是的 | |
| mapping （要写入的字段） |
array |
是的 | |
| opcode_field | string |
负载中保存数据库中此记录的作（c - 创建、d - 删除、u - 更新）的字段名称 |
是的 |
其他属性：不允许
例
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
On this page