Package org.apache.nifi.processors.standard

Class AbstractQueryDatabaseTable.MaxValueResultSetRowCollector

java.lang.Object

org.apache.nifi.processors.standard.AbstractQueryDatabaseTable.MaxValueResultSetRowCollector

All Implemented Interfaces:

JdbcCommon.ResultSetRowCallback

Enclosing class:

AbstractQueryDatabaseTable

public class AbstractQueryDatabaseTable.MaxValueResultSetRowCollector
extends Object
implements JdbcCommon.ResultSetRowCallback

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Map<String,String>	newColMap
(package private) final Map<String,String>	originalState
(package private) String	tableName

Constructor Summary

Constructors

Constructor	Description
MaxValueResultSetRowCollector(String tableName, Map<String,String> stateMap)

Method Summary

Modifier and Type	Method	Description
void	applyStateChanges()
void	processRow(ResultSet resultSet)

Methods inherited from class java.lang.Object

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

Field Details

newColMap

final Map<String,String> newColMap

originalState

final Map<String,String> originalState

tableName

String tableName

Constructor Details

MaxValueResultSetRowCollector

public MaxValueResultSetRowCollector(String tableName,
 Map<String,String> stateMap)

Method Details

processRow

public void processRow(ResultSet resultSet)
                throws IOException

Specified by:

processRow in interface JdbcCommon.ResultSetRowCallback

Throws:

IOException

applyStateChanges

public void applyStateChanges()

Specified by:

applyStateChanges in interface JdbcCommon.ResultSetRowCallback