We should fix the docs Would you be able to create a jira for that? On Monday, July 21, 2014, Sharninder <sharnin...@gmail.com> 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. > > Your explanation helps. > > -- > Sharninder > > On 21-Jul-2014, at 8:33 pm, Jeff Lord <jl...@cloudera.com > <javascript:_e(%7B%7D,'cvml','jl...@cloudera.com');>> wrote: > > 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 <sharnin...@gmail.com > <javascript:_e(%7B%7D,'cvml','sharnin...@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 >> >> >> >> >> >
