Are you trying to write directly from the interceptor to HBase? Or are you using the HBase sinks? You can use mutliplexing channel selector to push to different sinks based on the content, with each sink writing to a different table/cf.
Thanks, Hari On Wed, Apr 8, 2015 at 8:54 PM, Maheedhar Gunturu <[email protected]> wrote: > I am trying to build a small prototype of FLUME using custom interceptors. > I am looking to parse rsyslog using Custom Flume Regex interceptor and > input the values into various columns in one single column Family in hbase. > Here is a sample set of log messages that I have. > Mar 20 07:42:54 node46 ntpd[31266]: Deleting interface #4 em1, > fe80::862b:2bff:fefb:9065#123, interface stats: received=0, sent=0, > dropped=0, active_time=7995120 secs > As a next step I would like to select a few columns which can be input into > the respective columns in the column family. > One reference that I found is this article but it is very vague in the > description > https://questforthought.wordpress.com/2014/01/13/using-flume-interceptor-multiplexing/ > Can someone help. > - Vanguard_space
