Hermes@Neo4j
|
Public Member Functions | |
PipelineTemporal () | |
PipelineTemporal (final List< PipeTemporal > pipes) | |
PipelineTemporal (final PipeTemporal...pipes) | |
void | addPipe (final PipeTemporal pipe) |
void | setStarts (final Iterator< S > starts) |
void | setStarts (final Iterable< S > starts) |
void | remove () |
boolean | hasNext () |
E | next () |
List | getPath () |
int | size () |
void | reset () |
Iterator< E > | iterator () |
String | toString () |
List< PipeTemporal > | getPipes () |
Iterator< S > | getStarts () |
PipeTemporal | remove (final int index) |
PipeTemporal | get (final int index) |
boolean | equals (final Object object) |
long | count () |
void | iterate () |
List< E > | next (final int number) |
List< E > | toList () |
Collection< E > | fill (final Collection< E > collection) |
Public Member Functions inherited from Neo4jSpatiotemporal.pipes.impl.PipeTemporal< S, E > | |
void | setStarts (Iterator< S > starts) |
void | setStarts (Iterable< S > starts) |
Static Public Member Functions | |
static boolean | areEqual (final Iterator it1, final Iterator it2) |
Protected Member Functions | |
void | setPipes (final List< PipeTemporal > pipes) |
void | setPipes (final PipeTemporal...pipes) |
Protected Attributes | |
PipeTemporal< S,?> | startPipe |
PipeTemporal<?, E > | endPipe |
List< PipeTemporal > | pipes |
Iterator< S > | starts |
A Pipeline is a linear composite of Pipes. Pipeline takes a List of Pipes and joins them according to their order as specified by their location in the List. It is important to ensure that the provided ordered Pipes can connect together. That is, that the output type of the n-1 Pipe is the same as the input type of the n Pipe. Once all provided Pipes are composed, a Pipeline can be treated like any other Pipe.
Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.PipelineTemporal | ( | final List< PipeTemporal > | pipes | ) |
Constructs a pipeline from the provided pipes. The ordered list determines how the pipes will be chained together. When the pipes are chained together, the start of pipe n is the end of pipe n-1.
pipes | the ordered list of pipes to chain together into a pipeline |
Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.PipelineTemporal | ( | final PipeTemporal... | pipes | ) |
Constructs a pipeline from the provided pipes. The ordered array determines how the pipes will be chained together. When the pipes are chained together, the start of pipe n is the end of pipe n-1.
pipes | the ordered array of pipes to chain together into a pipeline |
void Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.addPipe | ( | final PipeTemporal | pipe | ) |
Adds a new pipe to the end of the pipeline and then reconstructs the pipeline chain.
pipe | the new pipe to add to the pipeline |
|
static |
long Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.count | ( | ) |
boolean Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.equals | ( | final Object | object | ) |
Collection<E> Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.fill | ( | final Collection< E > | collection | ) |
PipeTemporal Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.get | ( | final int | index | ) |
List Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.getPath | ( | ) |
Returns the transformation path to arrive at the current object of the pipe.
Implements Neo4jSpatiotemporal.pipes.impl.PipeTemporal< S, E >.
List<PipeTemporal> Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.getPipes | ( | ) |
Iterator<S> Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.getStarts | ( | ) |
boolean Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.hasNext | ( | ) |
Determines if there is another object that can be emitted from the pipeline.
void Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.iterate | ( | ) |
Iterator<E> Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.iterator | ( | ) |
Simply returns this as as a pipeline (more specifically, pipe) implements Iterator.
E Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.next | ( | ) |
Get the next object emitted from the pipeline. If no such object exists, then a NoSuchElementException is thrown.
List<E> Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.next | ( | final int | number | ) |
void Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.remove | ( | ) |
An unsupported operation that throws an UnsupportedOperationException.
PipeTemporal Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.remove | ( | final int | index | ) |
void Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.reset | ( | ) |
A pipe may maintain state. Reset is used to remove state. The general use case for reset() is to reuse a pipe in another computation without having to create a new Pipe object.
Implements Neo4jSpatiotemporal.pipes.impl.PipeTemporal< S, E >.
|
protected |
Useful for constructing the pipeline chain without making use of the constructor.
pipes | the ordered list of pipes to chain together into a pipeline |
|
protected |
Useful for constructing the pipeline chain without making use of the constructor.
pipes | the ordered array of pipes to chain together into a pipeline |
void Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.setStarts | ( | final Iterator< S > | starts | ) |
void Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.setStarts | ( | final Iterable< S > | starts | ) |
int Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.size | ( | ) |
Get the number of pipes in the pipeline.
List<E> Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.toList | ( | ) |
String Neo4jSpatiotemporal.pipes.impl.PipelineTemporal< S, E >.toString | ( | ) |
|
protected |
|
protected |
|
protected |
|
protected |