Class TridentOperationContext
java.lang.Object
org.apache.storm.trident.operation.TridentOperationContext
- All Implemented Interfaces:
IMetricsContext
-
Constructor Summary
ConstructorDescriptionTridentOperationContext
(TopologyContext topoContext, TridentTuple.Factory factory) TridentOperationContext
(TridentOperationContext parent, TridentTuple.Factory factory) -
Method Summary
Modifier and TypeMethodDescriptionint
makeProjectionFactory
(Fields fields) int
com.codahale.metrics.Counter
registerCounter
(String name) <T> com.codahale.metrics.Gauge<T>
registerGauge
(String name, com.codahale.metrics.Gauge<T> gauge) com.codahale.metrics.Histogram
registerHistogram
(String name) com.codahale.metrics.Meter
registerMeter
(String name) registerMetric
(String name, ICombiner combiner, int timeBucketSizeInSecs) Register metric.registerMetric
(String name, IReducer reducer, int timeBucketSizeInSecs) Register metric.<T extends IMetric>
TregisterMetric
(String name, T metric, int timeBucketSizeInSecs) Register metric.void
registerMetricSet
(String prefix, com.codahale.metrics.MetricSet set) com.codahale.metrics.Timer
registerTimer
(String name)
-
Constructor Details
-
TridentOperationContext
-
TridentOperationContext
-
-
Method Details
-
makeProjectionFactory
-
numPartitions
public int numPartitions() -
getPartitionIndex
public int getPartitionIndex() -
registerMetric
Description copied from interface:IMetricsContext
Register metric.- Specified by:
registerMetric
in interfaceIMetricsContext
-
registerMetric
Description copied from interface:IMetricsContext
Register metric.- Specified by:
registerMetric
in interfaceIMetricsContext
-
registerMetric
Description copied from interface:IMetricsContext
Register metric.- Specified by:
registerMetric
in interfaceIMetricsContext
-
registerTimer
- Specified by:
registerTimer
in interfaceIMetricsContext
-
registerHistogram
- Specified by:
registerHistogram
in interfaceIMetricsContext
-
registerMeter
- Specified by:
registerMeter
in interfaceIMetricsContext
-
registerCounter
- Specified by:
registerCounter
in interfaceIMetricsContext
-
registerGauge
public <T> com.codahale.metrics.Gauge<T> registerGauge(String name, com.codahale.metrics.Gauge<T> gauge) - Specified by:
registerGauge
in interfaceIMetricsContext
-
registerMetricSet
- Specified by:
registerMetricSet
in interfaceIMetricsContext
-