YPC  0.2.0
Public Types | Public Member Functions | Protected Member Functions | Protected Attributes | List of all members
hpda::processor::internal::json_to_data_batch_impl< OutputObjType > Class Template Reference
Inheritance diagram for hpda::processor::internal::json_to_data_batch_impl< OutputObjType >:
Inheritance graph
[legend]
Collaboration diagram for hpda::processor::internal::json_to_data_batch_impl< OutputObjType >:
Collaboration graph
[legend]

Public Types

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
 
- Public Types inherited from hpda::processor::internal::processor_base< std::string, OutputObjType >
typedef ::hpda::internal::processor_with_input< std::string > base
 
- Public Types inherited from hpda::internal::processor_with_output< OutputObjType >
typedef OutputObjType output_type
 
- Public Types inherited from hpda::internal::processor_with_input< std::string >
typedef std::string input_type
 

Public Member Functions

 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 ()
 
- Public Member Functions inherited from hpda::processor::internal::processor_base< std::string, OutputObjType >
 processor_base (::hpda::internal::processor_with_output< std::string > *upper_stream)
 
std::string input_value () const
 
- Public Member Functions inherited from hpda::functor
void reset_done_value ()
 
virtual void done_value ()
 
bool has_value () const
 
engineget_engine () const
 
void set_engine (engine *e)
 
void add_predecessor (functor *pred)
 
const std::vector< functor * > predecessors () const
 
- Public Member Functions inherited from hpda::internal::processor_with_input< std::string >
 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)
 

Protected Member Functions

bool parse_data ()
 

Protected Attributes

std::vector< OutputObjType > m_all_data
 
int m_next_data_index
 
data_item_picker_t m_func
 
item_transformer_t m_item_transformer
 
- Protected Attributes inherited from hpda::functor
bool m_has_value
 
std::vector< functor * > m_predecessors
 
enginem_engine
 
uint32_t m_status
 
- Protected Attributes inherited from hpda::internal::processor_with_input< std::string >
internal::processor_with_output< std::string > * m_upper_stream
 

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