跳转至

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

支持的数据类型

目前支持除 counterCustom 类型之外的所有类型。

下面列出类型转换列表:

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