flume-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Denes Arvay (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLUME-2880) how to config a custom hbase sink?
Date Tue, 12 Sep 2017 13:35:00 GMT

     [ https://issues.apache.org/jira/browse/FLUME-2880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Denes Arvay updated FLUME-2880:
-------------------------------
    Fix Version/s: notrack

> 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
>             Fix For: notrack
>
>
> 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.4.14#64029)

Mime
View raw message