Qore DataProvider Module Reference 2.7.3
Loading...
Searching...
No Matches
AbstractDataProcessor.qc.dox.h
1// -*- mode: c++; indent-tabs-mode: nil -*-
3
25// assume local scope for variables, do not use "$" signs
26// require type definitions everywhere
28// enable all warnings
29
31namespace DataProvider {
34
35public:
36protected:
38 *hash<auto> thread_local_data;
39
42
43public:
44
47
48
50
55
56
58
63
64
66
71
72
74
86 submit(code enqueue, auto _data);
87
88
90
99 flush(code enqueue);
100
101
103
105protected:
107public:
108
109
111
113protected:
115public:
116
117
119
130protected:
131 flushImpl(code enqueue);
132public:
133
134
136
142protected:
143 abstract submitImpl(code enqueue, auto _data);
144public:
145
147
151protected:
152 abstract bool supportsBulkApiImpl();
153public:
154};
155};
Defines an abstract class for accepting data and outputting optionally transformed or filtered data.
Definition: AbstractDataProcessor.qc.dox.h:33
submit(code enqueue, auto _data)
Submits the data for processing.
AbstractDataProviderType getReturnType()
Returns the type of data that will be returned, if available.
abstract submitImpl(code enqueue, auto _data)
Submits the data for processing.
*hash< auto > thread_local_data
Thread-local data to set before running the processor.
Definition: AbstractDataProcessor.qc.dox.h:38
AbstractDataProviderType getExpectedType()
Returns the expected type of data to be submitted, if available.
bool supportsBulkApi()
Returns True if the data processor supports bulk operation.
flush(code enqueue)
This method is called for each pipeline element to permit flushing of any pending data at the end of ...
abstract bool supportsBulkApiImpl()
Returns True if the data processor supports bulk operation.
*AbstractDataProviderType getReturnTypeImpl()
Returns the type of data that will be returned, if available.
*AbstractDataProviderType getExpectedTypeImpl()
Returns the expected type of data to be submitted, if available.
*list< string > thread_local_data_keys
Thread-local data keys from thread_local_data.
Definition: AbstractDataProcessor.qc.dox.h:41
flushImpl(code enqueue)
This method is called for each pipeline element to permit flushing of any pending data at the end of ...
setThreadLocalData(*hash< auto > thread_local_data)
Sets thread-local data to set before running the processor.
describes a data type
Definition: AbstractDataProviderType.qc.dox.h:206
Qore AbstractDataField class definition.
Definition: AbstractDataField.qc.dox.h:27