Java AbstractDataProcessor class.
More...
Java AbstractDataProcessor class.
- Since
- jni 1.2
◆ getExpectedType()
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()
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()
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()
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 {
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 |
|
abstractprivate |
Submits the data for processing.
- Example
void submitImpl(QoreClosure enqueue, Object _data)
throws Throwable {
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 |
( |
| ) |
|
|
abstractprivate |
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:
- /tmp/module-jni/src/java/org/qore/lang/dataprovider/AbstractDataProcessor.java
