public final class ProfileSideEffectStep<S> extends SideEffectStep<S> implements SideEffectCapable<DefaultTraversalMetrics,DefaultTraversalMetrics>, GraphComputing
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_METRICS_KEY |
id, labels, nextEnd, nextStep, previousStep, starts, traversal, traverserStepIdAndLabelsSetByChild
Constructor and Description |
---|
ProfileSideEffectStep(Traversal.Admin traversal,
String sideEffectKey) |
Modifier and Type | Method and Description |
---|---|
DefaultTraversalMetrics |
generateFinalResult(DefaultTraversalMetrics tm)
Post-process the side-effect and return the post-processed side-effect.
|
String |
getSideEffectKey()
The side-effect key of the step.
|
boolean |
hasNext() |
Traverser.Admin<S> |
next() |
void |
onGraphComputer()
The step will be executing on a
GraphComputer . |
protected void |
sideEffect(Traverser.Admin<S> traverser) |
processNextStart
addLabel, addStart, addStarts, clone, equals, getId, getLabels, getNextStep, getPreviousStep, getStarts, getTraversal, hashCode, isTraverserStepIdAndLabelsSetByChild, prepareTraversalForNextStep, removeLabel, reset, setId, setNextStep, setPreviousStep, setTraversal, toString
finalize, getClass, notify, notifyAll, wait, wait, wait
atMaster, atMaster
equals, getRequirements
forEachRemaining, remove
public static final String DEFAULT_METRICS_KEY
public ProfileSideEffectStep(Traversal.Admin traversal, String sideEffectKey)
protected void sideEffect(Traverser.Admin<S> traverser)
sideEffect
in class SideEffectStep<S>
public String getSideEffectKey()
SideEffectCapable
getSideEffectKey
in interface SideEffectCapable<DefaultTraversalMetrics,DefaultTraversalMetrics>
public Traverser.Admin<S> next()
next
in interface Iterator<Traverser.Admin<S>>
next
in class AbstractStep<S,S>
public boolean hasNext()
hasNext
in interface Iterator<Traverser.Admin<S>>
hasNext
in class AbstractStep<S,S>
public DefaultTraversalMetrics generateFinalResult(DefaultTraversalMetrics tm)
Generating
generateFinalResult
in interface Generating<DefaultTraversalMetrics,DefaultTraversalMetrics>
tm
- the pre-processed side-effect.public void onGraphComputer()
GraphComputing
GraphComputer
.onGraphComputer
in interface GraphComputing
Copyright © 2013–2021 Apache Software Foundation. All rights reserved.