跳到主要内容
版本:2.1.2

HBase

Description

Get data from HBase

提示

Engine Supported and plugin name

  • Spark: HBase
  • Flink

Options

nametyperequireddefault value
hbase.zookeeper.quorumstringyes
catalogstringyes
common-optionsstringyes-

hbase.zookeeper.quorum [string]

The address of the zookeeper cluster, the format is: host01:2181,host02:2181,host03:2181

catalog [string]

The structure of the hbase table is defined by catalog , the name of the hbase table and its namespace , which columns are used as rowkey, and the correspondence between column family and columns can be defined by catalog hbase table catalog

common options [string]

Source plugin common parameters, please refer to Source Plugin for details

Example

  Hbase {
hbase.zookeeper.quorum = "localhost:2181"
catalog = "{\"table\":{\"namespace\":\"default\", \"name\":\"test\"},\"rowkey\":\"id\",\"columns\":{\"id\":{\"cf\":\"rowkey\", \"col\":\"id\", \"type\":\"string\"},\"a\":{\"cf\":\"f1\", \"col\":\"a\", \"type\":\"string\"},\"b\":{\"cf\":\"f1\", \"col\":\"b\", \"type\":\"string\"},\"c\":{\"cf\":\"f1\", \"col\":\"c\", \"type\":\"string\"}}}"
result_table_name = "my_dataset"
}