org.apache.tinkerpop.gremlin.process.traversal.util

Class DependantMutableMetrics

java.lang.Object

org.apache.tinkerpop.gremlin.process.traversal.util.ImmutableMetrics

org.apache.tinkerpop.gremlin.process.traversal.util.MutableMetrics

org.apache.tinkerpop.gremlin.process.traversal.util.DependantMutableMetrics

All Implemented Interfaces:

Serializable, Cloneable, Metrics

public class DependantMutableMetrics
extends MutableMetrics

This Metrics class handles a metrics chain in which durations are "double counted" by upstream metrics. Durations are corrected on-the-fly by subtracting upstream durations on every call to stop().

Author:

Bob Briody (http://bobbriody.com)

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.tinkerpop.gremlin.process.traversal.util.ImmutableMetrics

annotations, counts, durationNs, id, name, nested

Constructor Summary

Constructors

Constructor and Description
DependantMutableMetrics(String id, String name, DependantMutableMetrics upStreamMetrics)

Method Summary

Modifier and Type	Method and Description
long	getAndResetIncrementalDur()
void	start()
void	stop()

Methods inherited from class org.apache.tinkerpop.gremlin.process.traversal.util.MutableMetrics

addNested, aggregate, clone, getImmutableClone, getNested, incrementCount, setAnnotation, setCount, setDuration

Methods inherited from class org.apache.tinkerpop.gremlin.process.traversal.util.ImmutableMetrics

getAnnotation, getAnnotations, getCount, getCounts, getDuration, getId, getName, getNested, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

DependantMutableMetrics

public DependantMutableMetrics(String id,
                               String name,
                               DependantMutableMetrics upStreamMetrics)

Method Detail

start

public void start()

Overrides:

start in class MutableMetrics

stop

public void stop()

Overrides:

stop in class MutableMetrics

getAndResetIncrementalDur

public long getAndResetIncrementalDur()