public class ResultSetPartitioner<STATE extends IPartitionedState>
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
void |
doPartition(IPartitionedIO<STATE> partitionedIO,
STATE state)
Import the whole partition of an input stream by starting a transaction, getting the related objects
stored in the destination, invoke the IOs partition handling and commit the transaction
|
java.util.Map<java.lang.String,? extends CdmBase> |
getObjectMap(java.lang.Object key) |
java.sql.ResultSet |
getResultSet()
Returns the underlying resultSet holding all records needed to handle the partition.
|
protected org.springframework.transaction.TransactionStatus |
getTransaction(int recordsPerTransaction,
IPartitionedIO partitionedIO) |
static <T extends IPartitionedState> |
NewInstance(Source source,
java.lang.String strIdQuery,
java.lang.String strRecordQuery,
int partitionSize) |
boolean |
nextPartition()
Increases the partition counter and generates the
currentIdLists for this partition |
void |
startDoSave() |
public static <T extends IPartitionedState> ResultSetPartitioner<T> NewInstance(Source source, java.lang.String strIdQuery, java.lang.String strRecordQuery, int partitionSize) throws java.sql.SQLException
java.sql.SQLException
public void doPartition(IPartitionedIO<STATE> partitionedIO, STATE state)
partitionedIO
- public void startDoSave()
public boolean nextPartition() throws java.sql.SQLException
currentIdLists
for this partitionjava.sql.SQLException
public java.sql.ResultSet getResultSet()
public java.util.Map<java.lang.String,? extends CdmBase> getObjectMap(java.lang.Object key)
protected org.springframework.transaction.TransactionStatus getTransaction(int recordsPerTransaction, IPartitionedIO partitionedIO)
recordsPerTransaction
- partitionedIO
- i
- Copyright © 2007-2020 EDIT. All Rights Reserved.