org.apache.tinkerpop.gremlin.process.traversal.step.map

Class MergeVertexStep<S>

java.lang.Object

org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep<S,E>

org.apache.tinkerpop.gremlin.process.traversal.step.map.FlatMapStep<S,Vertex>

org.apache.tinkerpop.gremlin.process.traversal.step.map.MergeVertexStep<S>

All Implemented Interfaces:

Serializable, AutoCloseable, Cloneable, Iterator<Traverser.Admin<Vertex>>, Step<S,Vertex>, Configuring, Mutating<Event>, Parameterizing, TraversalOptionParent<Merge,S,Vertex>, TraversalParent

Direct Known Subclasses:

TinkerMergeVertexStep

public class MergeVertexStep<S>
extends FlatMapStep<S,Vertex>
implements Mutating<Event>, TraversalOptionParent<Merge,S,Vertex>

Implementation for the mergeV() step covering both the start step version and the one used mid-traversal.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected CallbackRegistry<Event>	callbackRegistry

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

id, labels, nextEnd, nextStep, previousStep, starts, traversal, traverserStepIdAndLabelsSetByChild

Constructor Summary

Constructors

Constructor and Description
MergeVertexStep(Traversal.Admin traversal, boolean isStart)
MergeVertexStep(Traversal.Admin traversal, boolean isStart, Map<Object,Object> searchCreate)
MergeVertexStep(Traversal.Admin traversal, boolean isStart, Traversal.Admin<S,Map<Object,Object>> searchCreateTraversal)

Method Summary

Modifier and Type	Method and Description
void	addChildOption(Merge token, Traversal.Admin<S,Vertex> traversalOption) The child as defined by the token it takes, like Pick or Merge.
MergeVertexStep<S>	clone() Cloning is used to duplicate steps for the purpose of traversal optimization and OLTP replication.
void	configure(Object... keyValues) Accept a configuration to the Step.
protected Stream<Vertex>	createSearchStream(Map<Object,Object> search) Use the Map of search criteria to most efficiently return a Stream<Vertex> of matching elements.
protected Iterator<Vertex>	flatMap(Traverser.Admin<S> traverser)
CallbackRegistry<Event>	getCallbackRegistry()
<S,E> List<Traversal.Admin<S,E>>	getLocalChildren()
CallbackRegistry<Event>	getMutatingCallbackRegistry() Gets the callback registry for events that the step raises.
Traversal.Admin<S,Map<Object,Object>>	getOnCreateTraversal() Gets the traversal that will be used to provide the Map that will be the override to the one provided by the getSearchCreateTraversal() for vertex creation events.
Traversal.Admin<S,Map<String,Object>>	getOnMatchTraversal() Gets the traversal that will be used to provide the Map that will be used to modify vertices that match the search criteria of getSearchCreateTraversal().
Parameters	getParameters() Gets the parameters on the step.
Set<TraverserRequirement>	getRequirements() Provide the necessary TraverserRequirement that must be met by the traverser in order for the step to function properly.
Traversal.Admin<S,Map<Object,Object>>	getSearchCreateTraversal() Gets the traversal that will be used to provide the Map that will be used to search for vertices.
int	hashCode()
boolean	isFirst() Determine if this is the first pass through processNextStart().
boolean	isStart() Determines if this is a start step.
protected Traverser.Admin<Vertex>	processNextStart()
void	reset() Reset the state of the step such that it has no incoming starts.
void	setTraversal(Traversal.Admin<?,?> parentTraversal) Set the Traversal that this step is contained within.
String	toString()
static void	validateMapInput(Map<?,Object> m, boolean ignoreTokens) Validates input to any Map arguments to this step.

Methods inherited from class org.apache.tinkerpop.gremlin.process.traversal.step.map.FlatMapStep

closeIterator

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

addLabel, addStart, addStarts, equals, getId, getLabels, getNextStep, getPreviousStep, getStarts, getTraversal, hasNext, hasStarts, isTraverserStepIdAndLabelsSetByChild, next, prepareTraversalForNextStep, removeLabel, setId, setNextStep, setPreviousStep

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.tinkerpop.gremlin.process.traversal.step.TraversalParent

addGlobalChild, addLocalChild, asStep, close, getGlobalChildren, getSelfAndChildRequirements, integrateChild, removeGlobalChild, removeLocalChild, replaceLocalChild

Methods inherited from interface org.apache.tinkerpop.gremlin.process.traversal.Step

equals

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Field Detail

callbackRegistry

protected CallbackRegistry<Event> callbackRegistry

Constructor Detail

MergeVertexStep

public MergeVertexStep(Traversal.Admin traversal,
                       boolean isStart)

MergeVertexStep

public MergeVertexStep(Traversal.Admin traversal,
                       boolean isStart,
                       Map<Object,Object> searchCreate)

MergeVertexStep

public MergeVertexStep(Traversal.Admin traversal,
                       boolean isStart,
                       Traversal.Admin<S,Map<Object,Object>> searchCreateTraversal)

Method Detail

getSearchCreateTraversal

public Traversal.Admin<S,Map<Object,Object>> getSearchCreateTraversal()

Gets the traversal that will be used to provide the Map that will be used to search for vertices. This Map also will be used as the default data set to be used to create a vertex if the search is not successful.

getOnCreateTraversal

public Traversal.Admin<S,Map<Object,Object>> getOnCreateTraversal()

Gets the traversal that will be used to provide the Map that will be the override to the one provided by the getSearchCreateTraversal() for vertex creation events.

getOnMatchTraversal

public Traversal.Admin<S,Map<String,Object>> getOnMatchTraversal()

Gets the traversal that will be used to provide the Map that will be used to modify vertices that match the search criteria of getSearchCreateTraversal().

isStart

public boolean isStart()

Determines if this is a start step.

isFirst

public boolean isFirst()

Determine if this is the first pass through processNextStart().

getCallbackRegistry

public CallbackRegistry<Event> getCallbackRegistry()

addChildOption

public void addChildOption(Merge token,
                           Traversal.Admin<S,Vertex> traversalOption)

Description copied from interface: TraversalOptionParent

The child as defined by the token it takes, like Pick or Merge. This traversal may be of local or global scope depending on the step implementation that works with option().

Specified by:

addChildOption in interface TraversalOptionParent<Merge,S,Vertex>

getLocalChildren

public <S,E> List<Traversal.Admin<S,E>> getLocalChildren()

Specified by:

getLocalChildren in interface TraversalParent

configure

public void configure(Object... keyValues)

Description copied from interface: Configuring

Accept a configuration to the Step. Note that this interface extends Parameterizing and so there is an expectation that the Step implementation will have a Parameters instance that will house any values passed to this method. Storing these configurations in Parameters is not a requirement however, IF the configuration is an expected option for the step and can be stored on a member field that can be accessed on the step by more direct means (i.e. like a getter method).

Specified by:

configure in interface Configuring

getParameters

public Parameters getParameters()

Description copied from interface: Parameterizing

Gets the parameters on the step.

Specified by:

getParameters in interface Parameterizing

processNextStart

protected Traverser.Admin<Vertex> processNextStart()

Overrides:

processNextStart in class FlatMapStep<S,Vertex>

createSearchStream

protected Stream<Vertex> createSearchStream(Map<Object,Object> search)

Use the Map of search criteria to most efficiently return a Stream<Vertex> of matching elements. Providers might override this method when extending this step to provide their own optimized mechanisms for matching the list of vertices. This implementation is only optimized for the T.id so any other usage will simply be in-memory filtering which could be slow.

flatMap

protected Iterator<Vertex> flatMap(Traverser.Admin<S> traverser)

Specified by:

flatMap in class FlatMapStep<S,Vertex>

validateMapInput

public static void validateMapInput(Map<?,Object> m,
                                    boolean ignoreTokens)

Validates input to any Map arguments to this step. For Merge.onMatch updates cannot be applied to immutable parts of an Edge (id, label, incident vertices) so those can be ignored in the validation.

getMutatingCallbackRegistry

public CallbackRegistry<Event> getMutatingCallbackRegistry()

Description copied from interface: Mutating

Gets the callback registry for events that the step raises.

Specified by:

getMutatingCallbackRegistry in interface Mutating<Event>

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractStep<S,Vertex>

reset

public void reset()

Description copied from interface: Step

Reset the state of the step such that it has no incoming starts. Internal states are to be reset, but any sideEffect data structures are not to be recreated.

Specified by:

reset in interface Step<S,Vertex>

Overrides:

reset in class FlatMapStep<S,Vertex>

getRequirements

public Set<TraverserRequirement> getRequirements()

Description copied from interface: Step

Provide the necessary TraverserRequirement that must be met by the traverser in order for the step to function properly. The provided default implements returns an empty set.

Specified by:

getRequirements in interface Step<S,Vertex>

Returns:

the set of requirements

toString

public String toString()

Overrides:

toString in class AbstractStep<S,Vertex>

setTraversal

public void setTraversal(Traversal.Admin<?,?> parentTraversal)

Description copied from interface: Step

Set the Traversal that this step is contained within.

Specified by:

setTraversal in interface Step<S,Vertex>

Overrides:

setTraversal in class AbstractStep<S,Vertex>

Parameters:

parentTraversal - the new traversal for this step

clone

public MergeVertexStep<S> clone()

Description copied from interface: Step

Cloning is used to duplicate steps for the purpose of traversal optimization and OLTP replication. When cloning a step, it is important that the steps, the cloned step is equivalent to the state of the step when Step.reset() is called. Moreover, the previous and next steps should be set to EmptyStep.

Specified by:

clone in interface Step<S,Vertex>

Overrides:

clone in class AbstractStep<S,Vertex>

Returns:

The cloned step