public interface IMetricsConsumer
Modifier and Type | Interface and Description |
---|---|
static class |
IMetricsConsumer.DataPoint |
static class |
IMetricsConsumer.TaskInfo |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
void |
handleDataPoints(IMetricsConsumer.TaskInfo taskInfo,
Collection<IMetricsConsumer.DataPoint> dataPoints) |
void |
prepare(Map<String,Object> topoConf,
Object registrationArgument,
TopologyContext context,
IErrorReporter errorReporter) |
void prepare(Map<String,Object> topoConf, Object registrationArgument, TopologyContext context, IErrorReporter errorReporter)
void handleDataPoints(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints)
void cleanup()
Copyright © 2022 The Apache Software Foundation. All rights reserved.