com.exalead.papi.connectors.jdbc.columnprocessing

Class MaximumCheckpointProcessor

java.lang.Object

com.exalead.papi.connectors.jdbc.columnprocessing.ColumnProcessor

com.exalead.papi.connectors.jdbc.columnprocessing.MaximumCheckpointProcessor

public class MaximumCheckpointProcessor
extends ColumnProcessor

Field Summary

Fields

Modifier and Type	Field and Description
boolean	pushSerial
boolean	pushStamp
long	serial
java.sql.Timestamp	stamp

Fields inherited from class com.exalead.papi.connectors.jdbc.columnprocessing.ColumnProcessor

columnMapping, connector, document, logger, name, parameters, verbose

Constructor Summary

Constructors

Constructor and Description
MaximumCheckpointProcessor()

Method Summary

Modifier and Type	Method and Description
void	end() This method is called when synchronization is done.
void	processRow(ResultSetProxy row) This method is called when the connector a tuple should be processed

Methods inherited from class com.exalead.papi.connectors.jdbc.columnprocessing.ColumnProcessor

addParameters, buildURI, endDocument, error, getColumnMapping, getConnector, getDocument, getParameters, info, makeLogString, setColumnMapping, setConnector, setDocument, setParameters, start, startDocument, verbose, warning

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

pushSerial

public boolean pushSerial

pushStamp

public boolean pushStamp

serial

public long serial

stamp

public java.sql.Timestamp stamp

Constructor Detail

MaximumCheckpointProcessor

public MaximumCheckpointProcessor()

Method Detail

processRow

public void processRow(ResultSetProxy row)
                throws java.lang.Exception

Description copied from class: ColumnProcessor

This method is called when the connector a tuple should be processed

Specified by:

processRow in class ColumnProcessor

Throws:

java.lang.Exception

end

public void end()
         throws java.lang.Exception

Description copied from class: ColumnProcessor

This method is called when synchronization is done.

Overrides:

end in class ColumnProcessor

Throws:

java.lang.Exception