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

Interface PureQueryReaderPattern

public interface PureQueryReaderPattern

Method Summary

Methods

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

s -

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: