Flume, mail # dev - Custom sink/source - 2014-07-21, 12:26
Solr & Elasticsearch trainings in New York & San Francisco [more info][hide]
 Search Hadoop and all its subprojects:

Switch to Threaded View
Copy link to this message
Custom sink/source

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?


NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB