eu.ehri.project.utils.pipes

Class AggregatorPipe<E>

java.lang.Object

com.tinkerpop.pipes.AbstractPipe<E,List<E>>

eu.ehri.project.utils.pipes.AggregatorPipe<E>

All Implemented Interfaces:

com.tinkerpop.pipes.Pipe<E,List<E>>, com.tinkerpop.pipes.transform.TransformPipe<E,List<E>>, Iterable<List<E>>, Iterator<List<E>>

public class AggregatorPipe<E>
extends com.tinkerpop.pipes.AbstractPipe<E,List<E>>
implements com.tinkerpop.pipes.transform.TransformPipe<E,List<E>>

Pipe processor to aggregate item streams into lists given a comparator function that can compare neighbouring items.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AggregatorPipe.AggregatorFunction<T>

Nested classes/interfaces inherited from interface com.tinkerpop.pipes.transform.TransformPipe

com.tinkerpop.pipes.transform.TransformPipe.Order

Field Summary

Fields inherited from class com.tinkerpop.pipes.AbstractPipe

currentEnd, pathEnabled, starts

Fields inherited from interface com.tinkerpop.pipes.Pipe

NO_PATH_MESSAGE

Constructor Summary

Constructors

Constructor and Description
AggregatorPipe(AggregatorPipe.AggregatorFunction<E> function)

Method Summary

Modifier and Type	Method and Description
protected List<E>	processNextStart()
void	reset()

Methods inherited from class com.tinkerpop.pipes.AbstractPipe

enablePath, getCurrentPath, getPathToHere, hasNext, iterator, next, remove, setStarts, setStarts, setStarts, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.tinkerpop.pipes.Pipe

enablePath, getCurrentPath, setStarts, setStarts

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Constructor Detail

AggregatorPipe

public AggregatorPipe(AggregatorPipe.AggregatorFunction<E> function)

Method Detail

processNextStart

protected List<E> processNextStart()
                            throws NoSuchElementException

Specified by:

processNextStart in class com.tinkerpop.pipes.AbstractPipe<E,List<E>>

Throws:

NoSuchElementException

reset

public void reset()

Specified by:

reset in interface com.tinkerpop.pipes.Pipe<E,List<E>>

Overrides:

reset in class com.tinkerpop.pipes.AbstractPipe<E,List<E>>