com.twitter.heron.metricsmgr.sink

Class ScribeSink

java.lang.Object

com.twitter.heron.metricsmgr.sink.ScribeSink

All Implemented Interfaces:

IMetricsSink, java.lang.AutoCloseable

public class ScribeSink
extends java.lang.Object
implements IMetricsSink

A metrics sink that writes to Scribe with format required by Twitter Cuckoo

Constructor Summary

Constructors

Constructor and Description
ScribeSink()

Method Summary

Modifier and Type	Method and Description
void	close() Closes this stream and releases any system resources associated with it.
void	flush() Flush any buffered metrics It would be called at an interval according to the configuration
void	init(java.util.Map<java.lang.String,java.lang.Object> conf, SinkContext context) Initialize the MetricsSink
void	processRecord(MetricsRecord record) Process a metrics record in the sink

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScribeSink

public ScribeSink()

Method Detail

init

public void init(java.util.Map<java.lang.String,java.lang.Object> conf,
                 SinkContext context)

Description copied from interface: IMetricsSink

Initialize the MetricsSink

Specified by:

init in interface IMetricsSink

Parameters:

conf - An unmodifiableMap containing basic configuration

context - context objects for Sink to init Attempts to modify the returned map, whether direct or via its collection views, result in an UnsupportedOperationException.

processRecord

public void processRecord(MetricsRecord record)

Description copied from interface: IMetricsSink

Process a metrics record in the sink

Specified by:

processRecord in interface IMetricsSink

Parameters:

record - the record to put

flush

public void flush()

Description copied from interface: IMetricsSink

Flush any buffered metrics It would be called at an interval according to the configuration

Specified by:

flush in interface IMetricsSink

close

public void close()

Description copied from interface: IMetricsSink

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

Specified by:

close in interface IMetricsSink

Specified by:

close in interface java.lang.AutoCloseable