[jira] [Commented] (FLUME-2880) how to config a custom hbase sink?

["Ambud Sharma (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLUME-2880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15209841#comment-15209841 ] 

Ambud Sharma commented on FLUME-2880:
-------------------------------------

Yes, that is the ideal way to handle it, you don't want to change the Flume code and compile it there. Our APIs have been very stable for a while so most future updates to Flume should work without any major changes to your code (obviously you should rebuild with latest version if you are going to upgrade your agent)

> how to config a custom hbase sink?
> ----------------------------------
>
>                 Key: FLUME-2880
>                 URL: https://issues.apache.org/jira/browse/FLUME-2880
>             Project: Flume
>          Issue Type: Question
>            Reporter: Jack Jiang
>
> 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.huateng.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?
>  



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)