Inheritance diagram for hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >:

[legend]

Collaboration diagram for hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >:

[legend]

Public Types
typedef processor_base< InputObjType, OutputObjType >	base

Public Types inherited from hpda::processor::internal::processor_base< InputObjType, OutputObjType >
typedef ::hpda::internal::processor_with_input< InputObjType >	base

Public Types inherited from hpda::internal::processor_with_output< OutputObjType >
typedef OutputObjType	output_type

Public Types inherited from hpda::internal::processor_with_input< InputObjType >
typedef InputObjType	input_type

Public Member Functions
	groupby_impl (::hpda::internal::processor_with_output< InputObjType > *upper_stream, const AggregatorType &aggregator)

virtual bool	process ()

virtual OutputObjType	output_value ()

Public Member Functions inherited from hpda::processor::internal::processor_base< InputObjType, OutputObjType >
	processor_base (::hpda::internal::processor_with_output< InputObjType > *upper_stream)

InputObjType	input_value () const

Public Member Functions inherited from hpda::functor
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

Public Member Functions inherited from hpda::internal::processor_with_input< InputObjType >
	processor_with_input (processor_with_output< InputObjType > *input)

InputObjType	input_value () const

bool	has_input_value () const

void	consume_input_value ()

void	change_upper_stream (processor_with_output< InputObjType > *input)

Protected Attributes
typename ::ff::util::internal::nt_traits< GroupByType >::type	m_last_group_id

OutputObjType	m_data

AggregatorType	m_aggregator

bool	m_continue

Protected Attributes inherited from hpda::functor
bool	m_has_value

std::vector< functor * >	m_predecessors

engine *	m_engine

uint32_t	m_status

Protected Attributes inherited from hpda::internal::processor_with_input< InputObjType >
internal::processor_with_output< InputObjType > *	m_upper_stream

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

Public Types

Public Member Functions