flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 김태준 <kiora1...@gmail.com>
Subject Re: Monitoring custom sink
Date Tue, 03 Dec 2013 10:34:30 GMT
just want to use and control basic metrics

you can use below code

=====

privat SinkCounter counter

public synchronized void start() {
...
counter.start();
...
}







2013/12/3 김태준 <kiora1120@gmail.com>

> you can find class "org.apache.flume.instrumentation.SinkCounter"
>
> next, you must make "custom Counter Class" and "custom MBean Interface"
>
> like below code
>
> ===Class
> CustomSinkCounter extends SinkCounter implements CustomSinkCounterMBean
>
>
> ===Interface
> public interface CustomSinkCounterMBean extends SinkCounterMBean
>
>
>
>
>
>
> 2013/12/3 Himanshu Patidar <himanshu.patidar@hotmail.com>
>
>> Hi,
>>
>> I have written a custom sink which do some aggregation and send it to
>> HDFS.
>>
>> But I am unable to view the MBean metrics for this Sink. I can see the
>> metrics for channel and source though.
>>
>> Do I have to add something in the configuration or in the java code of my
>> custom sink.
>>
>> Any help?
>>
>> -------------
>> Himanshu
>>
>
>

Mime
View raw message