1. 程式人生 > >flume將多列資料寫入HBase的配置

flume將多列資料寫入HBase的配置

只列出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