Class TridentOperationContext
java.lang.Object
org.apache.storm.trident.operation.TridentOperationContext
- All Implemented Interfaces:
IMetricsContext
-
Constructor Summary
ConstructorsConstructorDescriptionTridentOperationContext(TopologyContext topoContext, TridentTuple.Factory factory) TridentOperationContext(TridentOperationContext parent, TridentTuple.Factory factory) -
Method Summary
Modifier and TypeMethodDescriptionintmakeProjectionFactory(Fields fields) intcom.codahale.metrics.CounterregisterCounter(String name) <T> com.codahale.metrics.Gauge<T>registerGauge(String name, com.codahale.metrics.Gauge<T> gauge) com.codahale.metrics.HistogramregisterHistogram(String name) com.codahale.metrics.MeterregisterMeter(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.voidregisterMetricSet(String prefix, com.codahale.metrics.MetricSet set) com.codahale.metrics.TimerregisterTimer(String name)
-
Constructor Details
-
TridentOperationContext
-
TridentOperationContext
-
-
Method Details
-
makeProjectionFactory
-
numPartitions
public int numPartitions() -
getPartitionIndex
public int getPartitionIndex() -
registerMetric
Description copied from interface:IMetricsContextRegister metric.- Specified by:
registerMetricin interfaceIMetricsContext
-
registerMetric
Description copied from interface:IMetricsContextRegister metric.- Specified by:
registerMetricin interfaceIMetricsContext
-
registerMetric
Description copied from interface:IMetricsContextRegister metric.- Specified by:
registerMetricin interfaceIMetricsContext
-
registerTimer
- Specified by:
registerTimerin interfaceIMetricsContext
-
registerHistogram
- Specified by:
registerHistogramin interfaceIMetricsContext
-
registerMeter
- Specified by:
registerMeterin interfaceIMetricsContext
-
registerCounter
- Specified by:
registerCounterin interfaceIMetricsContext
-
registerGauge
public <T> com.codahale.metrics.Gauge<T> registerGauge(String name, com.codahale.metrics.Gauge<T> gauge) - Specified by:
registerGaugein interfaceIMetricsContext
-
registerMetricSet
- Specified by:
registerMetricSetin interfaceIMetricsContext
-