Top Description Methods
com.ziclix.python.sql.pipe

public Interface Sink

Known Direct Implementers
com.ziclix.python.sql.pipe.csv.CSVSink, com.ziclix.python.sql.pipe.db.DBSink
Imports
org.python.core.PyObject
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

Method Summary

Modifier and TypeMethod and Description
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.

Method Detail

endback to summary
public 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.

rowback to summary
public 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.

startback to summary
public void start()

Invoked at the start of the data pipelining session.