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

Class MergeElementStep<S,E,C>

java.lang.Object

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

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

org.apache.tinkerpop.gremlin.process.traversal.step.map.MergeElementStep<S,E,C>

All Implemented Interfaces:

Serializable, AutoCloseable, Cloneable, Iterator<Traverser.Admin<E>>, Step<S,E>, Deleting<Event>, MergeStepContract<S,E,C>, Mutating<Event>, PopContaining, PropertiesHolder, TraversalOptionParent<Merge,S,C>, TraversalParent, Writing<Event>

Direct Known Subclasses:

MergeEdgeStep, MergeVertexStep

public abstract class MergeElementStep<S,E,C>
extends FlatMapStep<S,E>
implements MergeStepContract<S,E,C>

Abstract base class for the mergeV/E() implementations.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.process.traversal.step.PopContaining

PopContaining.PopInstruction

Field Summary

Fields

Modifier and Type	Field	Description
protected CallbackRegistry<Event>	callbackRegistry
protected boolean	first
protected final boolean	isStart
protected Traversal.Admin<S,Map>	mergeTraversal
protected Traversal.Admin<S,Map>	onCreateTraversal
protected Traversal.Admin<S,Map<String,?>>	onMatchTraversal
protected boolean	usesPartitionStrategy

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

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

Fields inherited from interface org.apache.tinkerpop.gremlin.process.traversal.step.map.MergeStepContract

CONCRETE_STEPS

Constructor Summary

Constructors

Constructor	Description
MergeElementStep(Traversal.Admin traversal, boolean isStart)
MergeElementStep(Traversal.Admin traversal, boolean isStart, Map mergeMap)
MergeElementStep(Traversal.Admin traversal, boolean isStart, Traversal.Admin mergeTraversal)

Method Summary

Modifier and Type	Method	Description
void	addChildOption(Merge token, Traversal.Admin<S,C> traversalOption)	The child as defined by the token it takes, like Pick or Merge.
void	addProperty(Object key, Object value)	This implementation should only be used as a mechanism for supporting PartitionStrategy.
MergeElementStep<S,E,C>	clone()	Cloning is used to duplicate steps for the purpose of traversal optimization and OLTP replication.
protected abstract Iterator<E>	flatMap(Traverser.Admin<S> traverser)
protected abstract Set	getAllowedTokens()
CallbackRegistry<Event>	getCallbackRegistry()
protected Graph	getGraph()
<S, C> List<Traversal.Admin<S,C>>	getLocalChildren()	Gets a list of all "local" child traversals for this step.
Traversal.Admin<S,Map>	getMergeTraversal()	Gets the traversal that will be used to provide the Map that will be used to search for elements.
CallbackRegistry<Event>	getMutatingCallbackRegistry()	Gets the callback registry for events that the step raises.
Traversal.Admin<S,Map>	getOnCreateTraversal()	Gets the traversal that will be used to provide the Map that will be used to create elements that do not match the search criteria of getMergeTraversal().
Traversal.Admin<S,Map<String,?>>	getOnMatchTraversal()	Gets the traversal that will be used to provide the Map that will be used to modify elements that match the search criteria of getMergeTraversal().
Map<Object,List<Object>>	getProperties()
Set<TraverserRequirement>	getRequirements()	Provide the necessary TraverserRequirement that must be met by the traverser in order for the step to function properly.
int	hashCode()
boolean	isFirst()	Determine if this is the first pass through processNextStart().
boolean	isStart()	Determines if this is a start step.
boolean	isUsingPartitionStrategy()
protected Map	materializeMap(Traverser.Admin<S> traverser, Traversal.Admin<S,?> mapTraversal)	null Map == empty Map
protected Traverser.Admin<E>	processNextStart()
boolean	removeProperty(Object k)
void	reset()	Reset the state of the step such that it has no incoming starts.
protected CloseableIterator<Vertex>	searchVertices(Map search)	Translate the Map into a g.V() traversal against the supplied graph.
protected GraphTraversal	searchVerticesLabelConstraint(GraphTraversal t, Object labelValue)
protected GraphTraversal	searchVerticesPropertyConstraints(GraphTraversal t, Map search)
protected GraphTraversal	searchVerticesTraversal(Graph graph, Object id)
void	setMerge(Traversal.Admin<?,Map<Object,Object>> mergeTraversal)
void	setOnCreate(Traversal.Admin<?,Map<Object,Object>> onCreateTraversal)
void	setOnMatch(Traversal.Admin<?,Map<Object,Object>> onMatchTraversal)
void	setTraversal(Traversal.Admin<?,?> parentTraversal)	Set the Traversal that this step is contained within.
String	toString()
protected void	validate(Map map, boolean ignoreTokens)
protected static void	validate(Map map, boolean ignoreTokens, Set allowedTokens, String op)
static void	validateNoOverrides(Map<?,?> mergeMap, Map<?,?> onCreateMap)	Prohibit overrides to the existence criteria (id/label/from/to) in onCreate.
static void	validateStaticNoOverrides(Traversal.Admin search, Traversal.Admin create)

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, clearLabels, 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 java.util.Iterator

forEachRemaining, remove

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

getMergeMapWithGValue, getOnCreateMapWithGValue, getOnMatchMapWithGValue

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

getPropertiesWithGValues

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

equals

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

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

Field Details

isStart

protected final boolean isStart

first

protected boolean first

mergeTraversal

protected Traversal.Admin<S,Map> mergeTraversal

onCreateTraversal

protected Traversal.Admin<S,Map> onCreateTraversal

onMatchTraversal

protected Traversal.Admin<S,Map<String,?>> onMatchTraversal

callbackRegistry

protected CallbackRegistry<Event> callbackRegistry

usesPartitionStrategy

protected boolean usesPartitionStrategy

Constructor Details

MergeElementStep

public MergeElementStep(Traversal.Admin traversal,
 boolean isStart)

MergeElementStep

public MergeElementStep(Traversal.Admin traversal,
 boolean isStart,
 Map mergeMap)

MergeElementStep

public MergeElementStep(Traversal.Admin traversal,
 boolean isStart,
 Traversal.Admin mergeTraversal)

Method Details

getMergeTraversal

public Traversal.Admin<S,Map> getMergeTraversal()

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

Specified by:

getMergeTraversal in interface MergeStepContract<S,E,C>

getOnCreateTraversal

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

Gets the traversal that will be used to provide the Map that will be used to create elements that do not match the search criteria of getMergeTraversal().

Specified by:

getOnCreateTraversal in interface MergeStepContract<S,E,C>

getOnMatchTraversal

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

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

Specified by:

getOnMatchTraversal in interface MergeStepContract<S,E,C>

isStart

public boolean isStart()

Determines if this is a start step.

Specified by:

isStart in interface MergeStepContract<S,E,C>

isFirst

public boolean isFirst()

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

Specified by:

isFirst in interface MergeStepContract<S,E,C>

getCallbackRegistry

public CallbackRegistry<Event> getCallbackRegistry()

addChildOption

public void addChildOption(Merge token,
 Traversal.Admin<S,C> 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<S,E,C>

getLocalChildren

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

Description copied from interface: TraversalParent

Gets a list of all "local" child traversals for this step. A "local" traversal is one which is evaluated independently for each incoming traverser to the parent step. This is typically used in cases where the child is used to process or augment each traverser individually. See LocalStep or ByModulating as examples.

Specified by:

getLocalChildren in interface TraversalParent

isUsingPartitionStrategy

public boolean isUsingPartitionStrategy()

Specified by:

isUsingPartitionStrategy in interface MergeStepContract<S,E,C>

processNextStart

protected Traverser.Admin<E> processNextStart()

Overrides:

processNextStart in class FlatMapStep<S,E>

getGraph

protected Graph getGraph()

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<S>

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractStep<S,E>

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 MergeStepContract<S,E,C>

Specified by:

reset in interface Step<S,E>

Overrides:

reset in class FlatMapStep<S,E>

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 MergeStepContract<S,E,C>

Specified by:

getRequirements in interface Step<S,E>

Returns:

the set of requirements

toString

public String toString()

Overrides:

toString in class AbstractStep<S,E>

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,E>

Overrides:

setTraversal in class AbstractStep<S,E>

Parameters:

parentTraversal - the new traversal for this step

clone

public MergeElementStep<S,E,C> 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,E>

Overrides:

clone in class AbstractStep<S,E>

Returns:

The cloned step

validate

protected void validate(Map map,
 boolean ignoreTokens)

validate

protected static void validate(Map map,
 boolean ignoreTokens,
 Set allowedTokens,
 String op)

validateNoOverrides

public static void validateNoOverrides(Map<?,?> mergeMap,
 Map<?,?> onCreateMap)

Prohibit overrides to the existence criteria (id/label/from/to) in onCreate.

materializeMap

protected Map materializeMap(Traverser.Admin<S> traverser,
 Traversal.Admin<S,?> mapTraversal)

null Map == empty Map

searchVertices

protected CloseableIterator<Vertex> searchVertices(Map search)

Translate the Map into a g.V() traversal against the supplied graph. Graph providers will presumably optimize this traversal to use whatever indices are present and appropriate for efficiency. Callers are responsible for closing this iterator when finished.

searchVerticesTraversal

protected GraphTraversal searchVerticesTraversal(Graph graph,
 Object id)

searchVerticesLabelConstraint

protected GraphTraversal searchVerticesLabelConstraint(GraphTraversal t,
 Object labelValue)

searchVerticesPropertyConstraints

protected GraphTraversal searchVerticesPropertyConstraints(GraphTraversal t,
 Map search)

flatMap

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

Specified by:

flatMap in class FlatMapStep<S,E>

getAllowedTokens

protected abstract Set getAllowedTokens()

setMerge

public void setMerge(Traversal.Admin<?,Map<Object,Object>> mergeTraversal)

Specified by:

setMerge in interface MergeStepContract<S,E,C>

setOnCreate

public void setOnCreate(Traversal.Admin<?,Map<Object,Object>> onCreateTraversal)

Specified by:

setOnCreate in interface MergeStepContract<S,E,C>

setOnMatch

public void setOnMatch(Traversal.Admin<?,Map<Object,Object>> onMatchTraversal)

Specified by:

setOnMatch in interface MergeStepContract<S,E,C>

addProperty

public void addProperty(Object key,
 Object value)

This implementation should only be used as a mechanism for supporting PartitionStrategy.

Specified by:

addProperty in interface PropertiesHolder

getProperties

public Map<Object,List<Object>> getProperties()

Specified by:

getProperties in interface PropertiesHolder

removeProperty

public boolean removeProperty(Object k)

Specified by:

removeProperty in interface PropertiesHolder

validateStaticNoOverrides

public static void validateStaticNoOverrides(Traversal.Admin search,
 Traversal.Admin create)