com.ziclix.python.sql.pipe

Interface Source

All Known Implementing Classes:

DBSource

public interface Source

A Source produces data to be consumed by a Sink. The data can be generated from anywhere, but must follow the format detail in next().

See Also:

next(), Sink

Method Summary

Modifier and Type	Method and Description
void	end() Invoked at the end of processing.
PyObject	next() Return the next row from the source.
void	start() Invoked at the start of processing.

Method Detail

start

void start()

Invoked at the start of processing.

next

PyObject next()

Return the next row from the source. The following format:
[(colName, colType), (colName, colType), ...] for headers and:
[(col), (colName, colType), ...] for all other data must be used.

end

void end()

Invoked at the end of processing. This method is guarenteed to be called.