flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jeff Lord <jl...@cloudera.com>
Subject Re: Custom sink/source
Date Mon, 21 Jul 2014 15:03:45 GMT
start() is called when the agent is started and the sink component is then
calling process() will take a batch of events off the channel and send to
the next hop or terminal location.
stop() is called when the agent is shutdown and the sink component
resources are unloaded.
Have you seen the developer guide?

On Mon, Jul 21, 2014 at 5:26 AM, Sharninder <sharninder@gmail.com> wrote:

> Hey,
> I'm trying to write a new custom source/sink for flume and was going
> through the source of some of the existing sinks. Essentially to write a
> sink, I have to implement a start(), stop() and process().
> Now, my question is if I initiate a connection in start(), send an event
> in process, will I be opening another connection again for the second
> event? When is stop() called?
> Has anyone implemented a websocket sink that I could take a look at?
> --
> Sharninder

View raw message