48 Star 501 Fork 228

GVP袋鼠云 / chunjun

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
cassandrareader.md 2.97 KB
一键复制 编辑 原始数据 按行查看 历史
tudou 提交于 2021-02-05 18:05 . 1、新增Oracle LogMiner实时采集插件

Cassandra Reader

一、插件名称

名称:cassandrareader

二、支持的数据源版本

Cassandra 3.0及以上

三、参数说明

  • host
    • 描述:数据库地址
    • 必选:是
    • 默认值:无
    • 字段类型:String

  • port
    • 描述:端口
    • 必选:否
    • 默认值:9042
    • 字段类型:Integer

  • username
    • 描述:用户名
    • 必选:否
    • 默认值:无
    • 字段类型:String

  • password
    • 描述:密码
    • 必选:否
    • 默认值:无
    • 字段类型:String

  • useSSL
    • 描述:数字证书
    • 必选:否
    • 默认值:false
    • 字段类型:boolean

  • column
    • 描述:查询结果中被select出来的属性集合,为空则select *
    • 必选:否
    • 默认值:无
    • 字段类型:List

  • keyspace
    • 描述:需要同步的表所在的keyspace
    • 必选:是
    • 默认值:无
    • 字段类型:String

  • table
    • 描述:要查询的表
    • 必选:是
    • 默认值:无
    • 字段类型:String

  • where
    • 描述:过滤条件where之后的表达式
    • 必选:否
    • 默认值:无
    • 字段类型:String

  • allowFiltering
    • 描述:是否在服务端过滤数据
    • 必选:否
    • 默认值:false
    • 字段类型:boolean

  • connecttionsPerHost
    • 描述:分配给每个host的连接数
    • 必选:否
    • 默认值:8
    • 字段类型:Integer

  • maxPendingPerConnection
    • 描述:最多能建立的连接数
    • 必选:否
    • 默认值:128
    • 字段类型:Integer

  • consistancyLevel
    • 描述:数据一致性级别。可选ONEQUORUMLOCAL_QUORUMEACH_QUORUMALLANYTWOTHREELOCAL_ONE
    • 必选:否
    • 默认值:无
    • 字段类型:String

四、配置示例

{
  "job" : {
    "content" : [ {
      "reader": {
        "name": "cassandrareader",
        "parameter": {
          "host": "kudu3",
          "port": 9042,
          "username":"",
          "password":"",
          "useSSL":false,
          "column": [
            {
              "name": "rowkey",
              "type": "string"
            },
            {
              "name": "cf1:id",
              "type": "string"
            }
          ]
        }
      },
      "writer": {
        "name": "streamwriter",
        "parameter": {
          "print": true
        }
      }
    }
    ],
    "setting": {
      "speed": {
        "channel": 1,
        "bytes": 0
      },
      "errorLimit": {
        "record": 1
      },
      "restore": {
        "maxRowNumForCheckpoint": 0,
        "isRestore": false,
        "restoreColumnName": "",
        "restoreColumnIndex": 0
      },
      "log" : {
        "isLogger": false,
        "level" : "debug",
        "path" : "",
        "pattern":""
      }
    }
  }
}
Java
1
https://gitee.com/dtstack_dev_0/chunjun.git
git@gitee.com:dtstack_dev_0/chunjun.git
dtstack_dev_0
chunjun
chunjun
1.10_release

搜索帮助