eu.larkc.core.executor.pipe
Class Source

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

public class Source
extends java.lang.Object

This class implements a source. A source is used to give an input to a workflow.

Author:

norbert

Constructor Summary

Source()
Constructor to create a new source.

Method Summary

void	putQuery(SetOfStatements query) This method starts the execution of the workflow.
void	setPipeInputQueue(Queue<SetOfStatements> inputQueue) Sets the input queue which is used to give the query to the workflow.

Methods inherited from class java.lang.Object

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

Constructor Detail

Source

public Source()

Constructor to create a new source.

Method Detail

putQuery

public void putQuery(SetOfStatements query)

This method starts the execution of the workflow.

Parameters:

query - The query which is passed to the workflow.

setPipeInputQueue

public void setPipeInputQueue(Queue<SetOfStatements> inputQueue)

Sets the input queue which is used to give the query to the workflow.

Parameters:

inputQueue - the input queue