question Can Flume be used with HBase? How? in Archives of Support Questions (Read Only)

Can Flume be used with HBase? How?

rushikeshdeshmu — Sat, 12 Mar 2016 15:58:17 GMT

Hi,

Can anyone please explain if Flume be used with HBase and how we can use it. If Possibly with example to help me understand.

Re: Can Flume be used with HBase? How?

rpednekar — Sat, 12 Mar 2016 16:03:55 GMT

This Apache document is good on Streaming data into Apache HBase using Apache Flume.

Re: Can Flume be used with HBase? How?

rushikeshdeshmu — Sat, 12 Mar 2016 16:08:15 GMT

@Rohan Pednekar, thanks for sharing this link.

Re: Can Flume be used with HBase? How?

rushikeshdeshmu — Sat, 12 Mar 2016 16:14:27 GMT

I got below answer:

Apache Flume can be used with HBase using one of the two HBase sinks –

HBaseSink (org.apache.flume.sink.hbase.HBaseSink) supports secure HBase clusters and also the novel HBase IPC that was introduced in the version HBase 0.96.
AsyncHBaseSink (org.apache.flume.sink.hbase.AsyncHBaseSink) has better performance than HBase sink as it can easily make non-blocking calls to HBase.

Working of the HBaseSink –

In HBaseSink, a Flume Event is converted into HBase Increments or Puts. Serializer implements the HBaseEventSerializer which is then instantiated when the sink starts. For every event, sink calls the initialize method in the serializer which then translates the Flume Event into HBase increments and puts to be sent to HBase cluster.

Working of the AsyncHBaseSink-

AsyncHBaseSink implements the AsyncHBaseEventSerializer. The initialize method is called only once by the sink when it starts. Sink invokes the setEvent method and then makes calls to the getIncrements and getActions methods just similar to HBase sink. When the sink stops, the cleanUp method is called by the serializer.

Re: Can Flume be used with HBase? How?

aervits — Sat, 12 Mar 2016 17:00:12 GMT

Here's info on both HBase sinks in Flume along with examples https://flume.apache.org/FlumeUserGuide.html#hbasesinks

Alternatively, if you're using Phoenix, there's a connector for that https://phoenix.apache.org/flume.html

Re: Can Flume be used with HBase? How?

rushikeshdeshmu — Sat, 12 Mar 2016 17:04:20 GMT

@Artem Ervits, thanks for sharing this link.