start() is called when the agent is started and the sink component is then started. 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? https://flume.apache.org/FlumeDeveloperGuide.html#sink On Mon, Jul 21, 2014 at 5:26 AM, Sharninder <[EMAIL PROTECTED]> wrote:
I did look at the developer guide and was a little confused since there seem to be a couple of omissions in it. In particular, the even based source isn't explained very well. I'm new to Java (and flume) so maybe that's just me.
We should fix the docs Would you be able to create a jira for that?
On Monday, July 21, 2014, Sharninder <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext