Skip to content

Latest commit

 

History

History
185 lines (155 loc) · 3.2 KB

cassandrawriter.md

File metadata and controls

185 lines (155 loc) · 3.2 KB

Cassandra Writer

一、插件名称

名称：cassandrawriter

二、支持的数据源版本

Cassandra 3.0及以上

三、参数说明

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

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

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

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

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

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

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

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

  • batchSize
    • 描述：异步写入的批次大小
    • 必选：否
    • 默认值：1
    • 字段类型：Integer

  • asyncWrite
    • 描述：是否异步写入
    • 必选：否
    • 默认值：false
    • 字段类型：Boolean

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

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

  • consistancyLevel
    • 描述：数据一致性级别。可选ONE、QUORUM、LOCAL_QUORUM、EACH_QUORUM、ALL、ANY、TWO、THREE、LOCAL_ONE
    • 必选：否
    • 默认值：无
    • 字段类型：String

四、配置示例

{
  "job" : {
    "content" : [ {
      "reader": {
        "name": "streamreader",
        "parameter": {
          "column": [
            {
              "name": "rowkey",
              "type": "string"
            },
            {
              "name": "id",
              "type": "string"
            }
          ],
          "sliceRecordCount" : ["100"]
        }
      },
      "writer": {
        "name": "cassandrawriterer",
        "parameter": {
          "host": "kudu3",
          "port": 9042,
          "username":"",
          "password":"",
          "useSSL":false,
          "column": [
            {
              "name": "rowkey",
              "type": "string"
            },
            {
              "name": "cf1:id",
              "type": "string"
            }
          ]
        }
      }
    } ],
    "setting": {
      "speed": {
        "channel": 1,
        "bytes": 0
      },
      "errorLimit": {
        "record": 100
      },
      "restore": {
        "maxRowNumForCheckpoint": 0,
        "isRestore": false,
        "isStream" : false,
        "restoreColumnName": "",
        "restoreColumnIndex": 0
      },
      "log" : {
        "isLogger": false,
        "level" : "debug",
        "path" : "",
        "pattern":""
      }
    }
  }
}