flume将多列数据写入HBase的配置,flumehbase
只列出sink部分的配置如下:
a1.sinks.k1.type = hbase
#命名空间和表名
a1.sinks.k1.table = ns1:t10
#列族
a1.sinks.k1.columnFamily = f1
a1.sinks.k1.serializer = org.apache.flume.sink.hbase.RegexHbaseEventSerializer
#指定列名称,数据的第一列为ROW_KEY
a1.sinks.k1.serializer.colNames = ROW_KEY,id,msg
#正则表达式
a1.sinks.k1.serializer.regex = (.*),(.*),(.*)
#指定字段的索引作为rowkey
a1.sinks.k1.serializer.rowKeyIndex = 0
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。