eu.larkc.core.executor.pipe
Class Pipe

java.lang.Object
  eu.larkc.core.executor.pipe.Pipe

All Implemented Interfaces:

PipeInterface

public class Pipe
extends java.lang.Object
implements PipeInterface

This class represents a pipe. One workflow can contain multiple pipes. Each pipe has to have exactly one source and one sink. Multiple endpoints can be assoziated with a pipe.

Author:

norbert

Constructor Summary

Pipe(Source source, Sink sink)
Custom constructor that takes a source and a sink as parameter.

Method Summary

void	execute(SetOfStatements query) Method to give the query to the source and execute the workflow.
SetOfStatements	getNextResults() Method to retrieve the next results from the workflow.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Pipe

public Pipe(Source source,
            Sink sink)

Custom constructor that takes a source and a sink as parameter.

Parameters:

source - the source.

sink - the sink.

Method Detail

execute

public void execute(SetOfStatements query)

Description copied from interface: PipeInterface

Method to give the query to the source and execute the workflow.

Specified by:

execute in interface PipeInterface

Parameters:

query - the query.

getNextResults

public SetOfStatements getNextResults()

Description copied from interface: PipeInterface

Method to retrieve the next results from the workflow.

Specified by:

getNextResults in interface PipeInterface

Returns:

The results of the execution.