org.qore.lang.dataprovider.AbstractDataProcessor Class Reference

Java AbstractDataProcessor class. More...

Public Member Methods
AbstractDataProviderType	getExpectedType ()
	Returns the expected type of data to be submitted, if available.
AbstractDataProviderType	getReturnType ()
	Returns the type of data that will be returned, if available.
boolean	supportsBulkApi ()
	Returns true if the data processor supports bulk operation.
void	submit (QoreClosure enqueue, Object _data) throws Throwable
	Submits the data for processing.

Private Member Methods
AbstractDataProviderType	getExpectedTypeImpl ()
	Returns the expected type of data to be submitted, if available.
AbstractDataProviderType	getReturnTypeImpl ()
	Returns the type of data that will be returned, if available.
abstract void	submitImpl (QoreClosure enqueue, Object _data) throws Throwable
	Submits the data for processing.
abstract boolean	supportsBulkApiImpl ()
	Returns true if the data processor supports bulk operation.

Detailed Description

Java AbstractDataProcessor class.

Since

jni 1.2

Deprecated

Use dynamic imports instead: import qoremod.DataProvider.AbstractDataProcessor;

Member Function Documentation

getExpectedType()

AbstractDataProviderType org.qore.lang.dataprovider.AbstractDataProcessor.getExpectedType ( )

inline

Returns the expected type of data to be submitted, if available.

Returns

the expected type of data to be submitted, if available

Note

Calls getExpectedTypeImpl() to provide the return value

getExpectedTypeImpl()

AbstractDataProviderType org.qore.lang.dataprovider.AbstractDataProcessor.getExpectedTypeImpl ( )

inlineprotected

Returns the expected type of data to be submitted, if available.

This base class method returns nothing; reimplement in subclasses to provide a type

getReturnType()

AbstractDataProviderType org.qore.lang.dataprovider.AbstractDataProcessor.getReturnType ( )

inline

Returns the type of data that will be returned, if available.

Returns

the type of data that will be returned, if available

Note

Calls getReturnTypeImpl() to provide the return value

getReturnTypeImpl()

AbstractDataProviderType org.qore.lang.dataprovider.AbstractDataProcessor.getReturnTypeImpl ( )

inlineprotected

Returns the type of data that will be returned, if available.

This base class method returns nothing; reimplement in subclasses to provide a type

submit()

void org.qore.lang.dataprovider.AbstractDataProcessor.submit ( QoreClosure enqueue, Object _data ) throws Throwable

inline

Submits the data for processing.

Example

void submitImpl(QoreClosure enqueue, Object _data) throws Throwable {
    // .. process the data and submit the modified data for onward processing
    enqueue.call(_data);
}
        enqueue.call(new_rec);

Parameters

enqueue	s closure taking a single arugment that enqueues the processed data for the next step in the pipeline; if no data should be processed onwards, do not call enqueue; if only one record should be processed onwards, then enqueue should be called only once; if multiple records are generated from the input data, then call it once for each generated record; prototype: code enqueue = sub (auto qdata) {}
_data	the data to process

Note

• Calls submitImpl() on the data to do the actual processing
• Accept and return type information is not enforced in this method; it must be enforced in submitImpl()
• Pipeline data can be of any type

submitImpl()

abstract void org.qore.lang.dataprovider.AbstractDataProcessor.submitImpl ( QoreClosure enqueue, Object _data ) throws Throwable

abstractprotected

Submits the data for processing.

Example

void submitImpl(QoreClosure enqueue, Object _data) throws Throwable {
    // .. process the data and submit the modified data for onward processing
    enqueue.call(_data);
}
        enqueue.call(new_rec);

Parameters

enqueue	s closure taking a single arugment that enqueues the processed data for the next step in the pipeline; if no data should be processed onwards, do not call enqueue; if only one record should be processed onwards, then enqueue should be called only once; if multiple records are generated from the input data, then call it once for each generated record; prototype: code enqueue = sub (auto qdata) {}
_data	the data to process

Note

Pipeline data can be of any type

supportsBulkApi()

boolean org.qore.lang.dataprovider.AbstractDataProcessor.supportsBulkApi ( )

inline

Returns true if the data processor supports bulk operation.

Returns

true if the data processor supports bulk operation

Note

Calls supportsBulkApiImpl() to return the answer

supportsBulkApiImpl()

abstract boolean org.qore.lang.dataprovider.AbstractDataProcessor.supportsBulkApiImpl ( )

abstractprotected

Returns true if the data processor supports bulk operation.

Returns

true if the data processor supports bulk operation

---

The documentation for this class was generated from the following file:

• src/java/org/qore/lang/dataprovider/AbstractDataProcessor.java