Cassandra Reader¶
CassandraReader
插件实现了从 Cassandra 读取数据的能力。
配置¶
下面是配置一个从 Cassandra 读取数据到终端的例子
{
"job": {
"setting": {
"speed": {
"channel": 1,
"bytes": -1
}
},
"content": {
"reader": {
"name": "cassandrareader",
"parameter": {
"host": "localhost",
"port": 9042,
"useSSL": false,
"keyspace": "test",
"table": "addax_src",
"column": [
"textCol",
"blobCol",
"writetime(blobCol)",
"boolCol",
"smallintCol",
"tinyintCol",
"intCol",
"bigintCol",
"varintCol",
"floatCol",
"doubleCol",
"decimalCol",
"dateCol",
"timeCol",
"timeStampCol",
"uuidCol",
"inetCol",
"durationCol",
"listCol",
"mapCol",
"setCol",
"tupleCol",
"udtCol"
]
}
},
"writer": {
"name": "streamwriter",
"parameter": {
"print": true
}
}
}
}
}
参数说明¶
配置项 | 是否必须 | 数据类型 | 默认值 | 描述 |
---|---|---|---|---|
host | 是 | list | 无 | 连接的域名或 IP,多个节点之间用逗号分隔 |
port | 是 | int | 9042 | 端口 |
username | 否 | string | 无 | 用户名 |
password | 否 | string | 无 | 密码 |
useSSL | 否 | boolean | false | 是否使用SSL连接 |
keyspace | 是 | string | 无 | 需要同步的表所在的 keyspace |
table | 是 | string | 无 | 所选取的需要同步的表 |
column | 是 | list | 无 | 所配置的表中需要同步的列集合,其中的元素可以指定列的名称或 writetime(column_name) ,后一种形式会读取column_name 列的时间戳而不是数据 |
where | 否 | string | 无 | 数据筛选条件的 cql 表达式 |
allowFiltering | 否 | boolean | 无 | 是否在服务端过滤数据,详细描述参考官方文档的相关描述 |
consistencyLevel | 否 | string | LOCAL_QUORUM | 数据一致性级别, 可选 ONE, QUORUM, LOCAL_QUORUM, EACH_QUORUM, ALL, ANY, TWO, THREE, LOCAL_ONE |
支持的数据类型¶
目前支持除 counter
和 Custom
类型之外的所有类型。
下面列出类型转换列表:
Addax 内部类型 | Cassandra 数据类型 |
---|---|
Long | int, tinyint, smallint,varint,bigint,time,counter |
Double | float, double, decimal |
String | ascii,varchar, text,uuid,timeuuid,duration,list,map,set,tuple,udt,inet |
Date | date, timestamp |
Boolean | bool |
Bytes | blob |