net.fortytwo.ripple.query

Class QueryPipe

java.lang.Object

net.fortytwo.ripple.query.QueryPipe

All Implemented Interfaces:

Sink<String>

public class QueryPipe
extends Object
implements Sink<String>

A pipeline for evaluating expressions in Ripple's text-based syntax. Each submitted String must be a complete, valid expression consisting of a sequence of programs and/or commands. Expressions are pushed into the QueryPipe using the put method, and the results flow from the other end of the pipe into the specified sink. Results arrive at any time and in any order, depending on the intermediate components of the pipe.

Constructor Summary

Constructors

Constructor and Description
QueryPipe(QueryEngine queryEngine, Sink<RippleList> resultSink)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
ModelConnection	getConnection()
void	put(InputStream input)
void	put(String expr) Passes a data item into the Sink

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryPipe

public QueryPipe(QueryEngine queryEngine,
         Sink<RippleList> resultSink)
          throws RippleException

Throws:

RippleException

Method Detail

getConnection

public ModelConnection getConnection()

close

public void close()
           throws RippleException

Throws:

RippleException

put

public void put(InputStream input)
         throws RippleException

Throws:

RippleException

put

public void put(String expr)
         throws RippleException

Description copied from interface: Sink

Passes a data item into the Sink

Specified by:

put in interface Sink<String>

Parameters:

expr - the data item being passed

Throws:

RippleException - if a data handling error occors