| com.ziclix.python.sql.pipe.Sink
All known Subclasses: com.ziclix.python.sql.pipe.db.DBSink, com.ziclix.python.sql.pipe.csv.CSVSink,
| Sink | | public interface Sink (Code) | | A Sink acts as a data consumer. The Pipe is responsible for pushing data
to the Sink as generated by the Source.
author:
brian zimmer
version:
$Revision: 2414 $ |
| Method Summary | |
| public void | end()
Invoked at the end of the data pipelining session. | | public void | row(PyObject row)
Invoked for each row of data. | | public void | start()
Invoked at the start of the data pipelining session. |
| end | | public void end()(Code) | | Invoked at the end of the data pipelining session. This is useful for
flushing any buffers or handling any cleanup. This method is guaranteed
to be called.
|
| row | | public void row(PyObject row)(Code) | | Invoked for each row of data. In general, the first row of data will
consist of header information in the format:
[(colName, colType), ...]
and in the format:
(colData, colData, ...)
for all other data.
|
| start | | public void start()(Code) | | Invoked at the start of the data pipelining session.
|
|
|