|
typedef std::function< const boost::property_tree::ptree &(const boost::property_tree::ptree &)> | data_item_picker_t |
|
typedef std::function< OutputObjType(const std::string &item)> | item_transformer_t |
|
typedef processor_base< std::string, OutputObjType > | base |
|
typedef ::hpda::internal::processor_with_input< std::string > | base |
|
typedef OutputObjType | output_type |
|
typedef std::string | input_type |
|
|
| json_to_data_batch_impl (::hpda::internal::processor_with_output< std::string > *upper_stream, const data_item_picker_t &data_item_picker, const item_transformer_t &item_transformer) |
|
virtual bool | process () |
|
virtual OutputObjType | output_value () |
|
| processor_base (::hpda::internal::processor_with_output< std::string > *upper_stream) |
|
std::string | input_value () const |
|
void | reset_done_value () |
|
virtual void | done_value () |
|
bool | has_value () const |
|
engine * | get_engine () const |
|
void | set_engine (engine *e) |
|
void | add_predecessor (functor *pred) |
|
const std::vector< functor * > | predecessors () const |
|
| processor_with_input (processor_with_output< std::string > *input) |
|
std::string | input_value () const |
|
bool | has_input_value () const |
|
void | consume_input_value () |
|
void | change_upper_stream (processor_with_output< std::string > *input) |
|
|
std::vector< OutputObjType > | m_all_data |
|
int | m_next_data_index |
|
data_item_picker_t | m_func |
|
item_transformer_t | m_item_transformer |
|
bool | m_has_value |
|
std::vector< functor * > | m_predecessors |
|
engine * | m_engine |
|
uint32_t | m_status |
|
internal::processor_with_output< std::string > * | m_upper_stream |
|
The documentation for this class was generated from the following file: