Package org.apache.storm.metric.api

Interface IMetricsConsumer

All Known Implementing Classes:

ForwardingMetricsConsumer, HttpForwardingMetricsConsumer, LoggingMetricsConsumer

public interface IMetricsConsumer

Nested Class Summary

Nested Classes

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

Method Summary

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

Method Detail

prepare

void prepare(Map<String,Object> topoConf,
             Object registrationArgument,
             TopologyContext context,
             IErrorReporter errorReporter)

handleDataPoints

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

cleanup

void cleanup()