com.exalead.papi.connectors.jdbc.columnprocessing

Class AutomaticProcessor

java.lang.Object

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

com.exalead.papi.connectors.jdbc.columnprocessing.AutomaticProcessor

public class AutomaticProcessor
extends ColumnProcessor

Field Summary

Fields

Modifier and Type	Field and Description
MultipleMetaProcessor	metaProcessor
MultiplePartProcessor	partProcessor

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

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

Constructor Summary

Constructors

Constructor and Description
AutomaticProcessor()

Method Summary

Modifier and Type	Method and Description
void	addParameters(java.lang.String key, java.lang.String value)
void	end() This method is called when synchronization is done.
void	endDocument() This method is called when the connector is about to send the document via the PushAPI.
void	processRow(ResultSetProxy row) This method is called when the connector a tuple should be processed
void	setColumnMapping(ColumnMapping columnMapping)
void	setConnector(DatabaseConnector connector)
void	setDocument(JDBCDocument document)
void	setParameters(java.util.Map<java.lang.String,java.lang.String> parameters)
void	start() This method is called the custom parameters has been filled and before the beginning of synchronization.
void	startDocument() This method is called when the connector begins to process a new PAPI document

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

buildURI, error, getColumnMapping, getConnector, getDocument, getParameters, info, makeLogString, verbose, warning

Methods inherited from class java.lang.Object

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

Field Detail

metaProcessor

public MultipleMetaProcessor metaProcessor

partProcessor

public MultiplePartProcessor partProcessor

Constructor Detail

AutomaticProcessor

public AutomaticProcessor()

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

start

public void start()
           throws java.lang.Exception

Description copied from class: ColumnProcessor

This method is called the custom parameters has been filled and before the beginning of synchronization.

Overrides:

start 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

startDocument

public void startDocument()
                   throws java.lang.Exception

Description copied from class: ColumnProcessor

This method is called when the connector begins to process a new PAPI document

Overrides:

startDocument in class ColumnProcessor

Throws:

java.lang.Exception

endDocument

public void endDocument()
                 throws java.lang.Exception

Description copied from class: ColumnProcessor

This method is called when the connector is about to send the document via the PushAPI. This call notifies the columnProcessor that pending operations should be applied to the document.

Overrides:

endDocument in class ColumnProcessor

Throws:

java.lang.Exception

setDocument

public void setDocument(JDBCDocument document)

Overrides:

setDocument in class ColumnProcessor

setColumnMapping

public void setColumnMapping(ColumnMapping columnMapping)

Overrides:

setColumnMapping in class ColumnProcessor

setParameters

public void setParameters(java.util.Map<java.lang.String,java.lang.String> parameters)

Overrides:

setParameters in class ColumnProcessor

addParameters

public void addParameters(java.lang.String key,
                          java.lang.String value)

Overrides:

addParameters in class ColumnProcessor

setConnector

public void setConnector(DatabaseConnector connector)

Overrides:

setConnector in class ColumnProcessor