Skip to content

Latest commit

 

History

History
172 lines (129 loc) · 2.82 KB

cassandrawriter.md

File metadata and controls

172 lines (129 loc) · 2.82 KB
Raw

Cassandra Writer

一、插件名称

名称：cassandrawriter

二、支持的数据源版本

Cassandra 3.0及以上

三、参数说明

  • host

    • 描述：数据库地址
    • 必选：是
    • 默认值：无

  • port

    • 描述：端口
    • 必选：否
    • 默认值：9042

  • username

    • 描述：用户名
    • 必选：否
    • 默认值：无

  • password

    • 描述：密码
    • 必选：否
    • 默认值：无

  • useSSL

    • 描述：数字证书
    • 必选：否
    • 默认值：false

  • column

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

  • keyspace

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

  • table

    • 描述：要查询的表
    • 必选：是
    • 默认值：无

  • batchSize

    • 描述：异步写入的批次大小
    • 必选：否
    • 默认值：1

  • asyncWrite

    • 描述：是否异步写入
    • 必选：否
    • 默认值：false

  • connecttionsPerHost

    • 描述：分配给每个host的连接数
    • 必选：否
    • 默认值：8

  • maxPendingPerConnection

    • 描述：最多能建立的连接数
    • 必选：否
    • 默认值：128

  • consistancyLevel

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

四、配置示例

{
  "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":""
      }
    }
  }
}