Class SqlgReducingStepBarrier<S,E>

java.lang.Object
org.umlg.sqlg.step.SqlgAbstractStep<S,E>
org.umlg.sqlg.step.barrier.SqlgReducingStepBarrier<S,E>
All Implemented Interfaces:
Serializable, Cloneable, Iterator<org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<E>>, org.apache.tinkerpop.gremlin.process.traversal.Step<S,E>
Direct Known Subclasses:
SqlgAvgGlobalStep, SqlgCountGlobalStep, SqlgFoldStep, SqlgGroupStep, SqlgMaxGlobalStep, SqlgMinGlobalStep, SqlgSumGlobalStep

public abstract class SqlgReducingStepBarrier<S,E> extends SqlgAbstractStep<S,E>
Author:
Pieter Martin Date: 2019/07/04
See Also:
  • Constructor Details

    • SqlgReducingStepBarrier

      public SqlgReducingStepBarrier(org.apache.tinkerpop.gremlin.process.traversal.Traversal.Admin<?,?> traversal)
  • Method Details

    • setSeedSupplier

      public void setSeedSupplier(Supplier<E> seedSupplier)
    • hasStarts

      public boolean hasStarts()
      Specified by:
      hasStarts in interface org.apache.tinkerpop.gremlin.process.traversal.Step<S,E>
      Overrides:
      hasStarts in class SqlgAbstractStep<S,E>
    • processNextStart

      protected org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<E> processNextStart() throws NoSuchElementException
      Specified by:
      processNextStart in class SqlgAbstractStep<S,E>
      Throws:
      NoSuchElementException
    • produceFinalResult

      protected org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<E> produceFinalResult(E result)
    • reduce

      public E reduce(E a, S b)
    • reset

      public void reset()
      Specified by:
      reset in interface org.apache.tinkerpop.gremlin.process.traversal.Step<S,E>
      Overrides:
      reset in class SqlgAbstractStep<S,E>