org.apache.storm.trident.operation

Class TridentOperationContext

java.lang.Object

org.apache.storm.trident.operation.TridentOperationContext

All Implemented Interfaces:

IMetricsContext

public class TridentOperationContext
extends Object
implements IMetricsContext

Constructor Summary

Constructors

Constructor and Description
TridentOperationContext(TopologyContext topoContext, TridentTuple.Factory factory)
TridentOperationContext(TridentOperationContext parent, TridentTuple.Factory factory)

Method Summary

Modifier and Type	Method and Description
int	getPartitionIndex()
TridentTupleView.ProjectionFactory	makeProjectionFactory(Fields fields)
int	numPartitions()
CombinedMetric	registerMetric(String name, ICombiner combiner, int timeBucketSizeInSecs)
ReducedMetric	registerMetric(String name, IReducer reducer, int timeBucketSizeInSecs)
<T extends IMetric> T	registerMetric(String name, T metric, int timeBucketSizeInSecs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TridentOperationContext

public TridentOperationContext(TopologyContext topoContext,
                               TridentTuple.Factory factory)

TridentOperationContext

public TridentOperationContext(TridentOperationContext parent,
                               TridentTuple.Factory factory)

Method Detail

makeProjectionFactory

public TridentTupleView.ProjectionFactory makeProjectionFactory(Fields fields)

numPartitions

public int numPartitions()

getPartitionIndex

public int getPartitionIndex()

registerMetric

public <T extends IMetric> T registerMetric(String name,
                                            T metric,
                                            int timeBucketSizeInSecs)

Specified by:

registerMetric in interface IMetricsContext

registerMetric

public ReducedMetric registerMetric(String name,
                                    IReducer reducer,
                                    int timeBucketSizeInSecs)

Specified by:

registerMetric in interface IMetricsContext

registerMetric

public CombinedMetric registerMetric(String name,
                                     ICombiner combiner,
                                     int timeBucketSizeInSecs)

Specified by:

registerMetric in interface IMetricsContext