You should be able to use "Flume Interceptors" ( http://flume.apache.org/FlumeUserGuide.html) to do this. Also, the HBase sink allows you to specify a serializer to help match events to Put records.
Brock On Mon, Aug 20, 2012 at 11:03 AM, João Ascenso <[email protected] > wrote: > Greetings, > > I'm currently storing log data using flume -> hdfs and was looking for a > way to alter the log data from the normal string format to a json > representation (and possibly in the future store in hbase). > > Is there any component in flume that i can use for this modification? i > remember seeing in the old documentation that you could use decorators, but > never found a good example or even if i can still use that in flume 1.x > > ------------------- > João Ascenso > -- Apache MRUnit - Unit testing MapReduce - http://incubator.apache.org/mrunit/
