flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sharninder <sharnin...@gmail.com>
Subject Custom sink/source
Date Mon, 21 Jul 2014 12:26:30 GMT

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?


View raw message