com.ibm.websphere.batch.devframework.datastreams.patternadapter

Interface PureQueryReaderPattern


  1. public interface PureQueryReaderPattern

Method Summary

Modifier and Type Method and Description
  1. java.lang.Object
fetchRecord(java.util.Iterator iterator)
Invoked by the container during each iteration of the batch loop.
  1. 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
  1. 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
  1. java.lang.String
getRestartTokens()
Invoked before a checkpoint is taken to save the restartToken that will be used in case of a restart
  1. void
initialize(java.util.Properties properties)
This method is called by the Batch container during step setup.

Method Detail

initialize

  1. 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

  1. 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

  1. 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

  1. java.util.Iterator getRestartIterator( com.ibm.pdq.runtime.Data data,
  2. java.lang.String restartToken)
Returns the Iterator based on the passed Data object repositioned based on the restartToken
Parameters:
data -
Returns:

getRestartTokens

  1. java.lang.String getRestartTokens( )
Invoked before a checkpoint is taken to save the restartToken that will be used in case of a restart
Returns: