| java.lang.Object
 com.ziclix.python.sql.pipe.Pipe
| Pipe | | public class Pipe (Code) | | Manager for a Sink and Source. The Pipe creates a Queue through which the Source
can feed data to the Sink. Both Sink and Source run in their own thread and can
are completely independent of the other. When the Source pushes None onto the
Queue, the piping is stopped and the Sink finishes processing all the remaining
data. This class is especially useful for loading/copying data from one database
or table to another.
author:
brian zimmer
version:
$Revision: 2414 $ |
| Constructor Summary | |
| public | Pipe()
Default empty constructor. |
| Pipe | | public Pipe()(Code) | | Default empty constructor.
|
| pipe | | public PyObject pipe(Source source, Sink sink)(Code) | | Start the processing of the Source->Sink.
Parameters:
source - the data generator
Parameters:
sink - the consumer of the data the number of rows seen (this includes the header row) |
|
|