backtype.storm.metric.api

Interface IMetricsConsumer

All Known Implementing Classes:

ForwardingMetricsConsumer, LoggingMetricsConsumer

public interface IMetricsConsumer

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	IMetricsConsumer.DataPoint
static class	IMetricsConsumer.TaskInfo

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup()
void	handleDataPoints(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints)
void	prepare(Map stormConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)

Method Detail

prepare

void prepare(Map stormConf,
           Object registrationArgument,
           TopologyContext context,
           IErrorReporter errorReporter)

handleDataPoints

void handleDataPoints(IMetricsConsumer.TaskInfo taskInfo,
                    Collection<IMetricsConsumer.DataPoint> dataPoints)

cleanup

void cleanup()