Package org.umlg.sqlg.step

Class SqlgGroupStep<K,V>

java.lang.Object

org.umlg.sqlg.step.SqlgAbstractStep<S,E>

org.umlg.sqlg.step.barrier.SqlgReducingStepBarrier<SqlgElement,Map<K,V>>

org.umlg.sqlg.step.SqlgGroupStep<K,V>

All Implemented Interfaces:

Serializable, Cloneable, Iterator<org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<Map<K,V>>>, org.apache.tinkerpop.gremlin.process.traversal.Step<SqlgElement,Map<K,V>>

public class SqlgGroupStep<K,V>
extends SqlgReducingStepBarrier<SqlgElement,Map<K,V>>

Author:

Pieter Martin Date: 2018/11/24

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	SqlgGroupStep.REDUCTION

Field Summary

Fields inherited from class org.umlg.sqlg.step.SqlgAbstractStep

starts

Constructor Summary

Constructors

Constructor	Description
SqlgGroupStep(org.apache.tinkerpop.gremlin.process.traversal.Traversal.Admin traversal, List<String> groupBy, String aggregateOn, boolean isPropertiesStep, SqlgGroupStep.REDUCTION reduction)

Method Summary

Modifier and Type	Method	Description
protected org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<Map<K,V>>	produceFinalResult(Map<K,V> result)
Map<K,V>	reduce(Map<K,V> end, SqlgElement sqlgElement)
void	reset()

Methods inherited from class org.umlg.sqlg.step.barrier.SqlgReducingStepBarrier

hasStarts, processNextStart, setSeedSupplier

Methods inherited from class org.umlg.sqlg.step.SqlgAbstractStep

addLabel, addStart, addStarts, clearLabels, clone, equals, getId, getLabels, getNextStep, getPreviousStep, getTraversal, hashCode, hasNext, next, removeLabel, setId, setNextStep, setPreviousStep, setTraversal, toString

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

equals, getRequirements

Constructor Details

SqlgGroupStep

public SqlgGroupStep(org.apache.tinkerpop.gremlin.process.traversal.Traversal.Admin traversal,
 List<String> groupBy,
 String aggregateOn,
 boolean isPropertiesStep,
 SqlgGroupStep.REDUCTION reduction)

Method Details

produceFinalResult

protected org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<Map<K,V>> produceFinalResult(Map<K,V> result)

Overrides:

produceFinalResult in class SqlgReducingStepBarrier<SqlgElement,Map<K,V>>

reduce

public Map<K,V> reduce(Map<K,V> end,
 SqlgElement sqlgElement)

Overrides:

reduce in class SqlgReducingStepBarrier<SqlgElement,Map<K,V>>

reset

public void reset()

Specified by:

reset in interface org.apache.tinkerpop.gremlin.process.traversal.Step<K,V>

Overrides:

reset in class SqlgReducingStepBarrier<SqlgElement,Map<K,V>>