com.ziclix.python.sql.pipe

Interface Sink

All Known Implementing Classes:

CSVSink, DBSink

public interface Sink

A Sink acts as a data consumer. The Pipe is responsible for pushing data to the Sink as generated by the Source.

Method Summary

Modifier and Type	Method and Description
void	end() Invoked at the end of the data pipelining session.
void	row(PyObject row) Invoked for each row of data.
void	start() Invoked at the start of the data pipelining session.

Method Detail

start

void start()

Invoked at the start of the data pipelining session.

row

void row(PyObject row)

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.

end

void end()

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.