com.ibm.websphere.batch.devframework.datastreams.patternadapter
Interface PureQueryReaderPattern
- public interface PureQueryReaderPattern
Method Summary
Modifier and Type | Method and Description |
---|---|
|
fetchRecord(java.util.Iterator iterator)
Invoked by the container during each iteration of the batch loop.
|
|
getInitialIterator(com.ibm.pdq.runtime.Data data)
Returns the Iterator based on the passed Data object that will be use to iterate over the records
|
|
getRestartIterator(com.ibm.pdq.runtime.Data data,java.lang.String restartToken)
Returns the Iterator based on the passed Data object repositioned based on the restartToken
|
|
getRestartTokens()
Invoked before a checkpoint is taken to save the restartToken that will be used in case of a restart
|
|
initialize(java.util.Properties properties)
This method is called by the Batch container during step setup.
|
Method Detail
initialize
- void initialize(java.util.Properties properties)
This method is called by the Batch container during step setup. The properties passed
in are the ones provided by the user in the xJCL BDS level properties
Parameters:
properties
- fetchRecord
- java.lang.Object fetchRecord(java.util.Iterator iterator)
Invoked by the container during each iteration of the batch loop. This obtains
the next record using the given Iterator object
Parameters:
iterator
- Returns:
getInitialIterator
- java.util.Iterator getInitialIterator( com.ibm.pdq.runtime.Data data)
Returns the Iterator based on the passed Data object that will be use to iterate over the records
Parameters:
data
- Returns:
getRestartIterator
- java.util.Iterator getRestartIterator( com.ibm.pdq.runtime.Data data,
- java.lang.String restartToken)
Returns the Iterator based on the passed Data object repositioned based on the restartToken
Parameters:
data
- Returns:
getRestartTokens
- java.lang.String getRestartTokens( )
Invoked before a checkpoint is taken to save the restartToken that will be used in case of a restart
Returns: