[FLUME-2880] how to config a custom hbase sink?

• Type: Question
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: notrack
• Assignee: Unassigned
• Reporter: Jack Jiang
• Created: 06/Feb/16 03:39
• Updated: 19/Jun/20 09:16
• Resolved: 21/Jul/16 01:48

Description

my flume version is 1.6.0 and i'm ready to sink logs to hbase,before this action,i need to process logs.so i defined a class named AsyncHbaseLogEventSerializer,it implements the interface of AsyncHbaseEventSerializer and i overwrite the method inside.here is my sink part of configuration file:
server.sinks.hdfs_sink.type = asynchbase
server.sinks.hdfs_sink.table = access_log
server.sinks.hdfs_sink.columnFamily = cb
server.sinks.hdfs_sink.serializer = com.xxxx.flume.sink.hbase.AsyncHbaseLogEventSerializer
server.sinks.hdfs_sink.serializer.columns = host_name,remote_host,remote_user,event_ts,req,req_status,resp_bytes,ref,agent
my question is should i package my own class as a jar package,and put it to lib?