add_predecessor(functor *pred) (defined in hpda::functor) | hpda::functor | inline |
base typedef (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | |
change_upper_stream(processor_with_output< InputObjType > *input) (defined in hpda::internal::processor_with_input< InputObjType >) | hpda::internal::processor_with_input< InputObjType > | inline |
consume_input_value() (defined in hpda::internal::processor_with_input< InputObjType >) | hpda::internal::processor_with_input< InputObjType > | inline |
done_value() (defined in hpda::functor) | hpda::functor | virtual |
functor() (defined in hpda::functor) | hpda::functor | |
get_engine() const (defined in hpda::functor) | hpda::functor | inline |
groupby_impl(::hpda::internal::processor_with_output< InputObjType > *upper_stream, const AggregatorType &aggregator) (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | inline |
has_input_value() const (defined in hpda::internal::processor_with_input< InputObjType >) | hpda::internal::processor_with_input< InputObjType > | inline |
has_value() const (defined in hpda::functor) | hpda::functor | inline |
input_type typedef (defined in hpda::internal::processor_with_input< InputObjType >) | hpda::internal::processor_with_input< InputObjType > | |
input_value() const (defined in hpda::processor::internal::processor_base< InputObjType, OutputObjType >) | hpda::processor::internal::processor_base< InputObjType, OutputObjType > | inline |
m_aggregator (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | protected |
m_continue (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | protected |
m_data (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | protected |
m_engine (defined in hpda::functor) | hpda::functor | protected |
m_has_value (defined in hpda::functor) | hpda::functor | protected |
m_last_group_id (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | protected |
m_predecessors (defined in hpda::functor) | hpda::functor | protected |
m_status (defined in hpda::functor) | hpda::functor | protected |
m_upper_stream (defined in hpda::internal::processor_with_input< InputObjType >) | hpda::internal::processor_with_input< InputObjType > | protected |
output_type typedef (defined in hpda::internal::processor_with_output< OutputObjType >) | hpda::internal::processor_with_output< OutputObjType > | |
output_value() (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | inlinevirtual |
predecessors() const (defined in hpda::functor) | hpda::functor | inline |
process() (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | inlinevirtual |
processor_base(::hpda::internal::processor_with_output< InputObjType > *upper_stream) (defined in hpda::processor::internal::processor_base< InputObjType, OutputObjType >) | hpda::processor::internal::processor_base< InputObjType, OutputObjType > | inline |
processor_with_input(processor_with_output< InputObjType > *input) (defined in hpda::internal::processor_with_input< InputObjType >) | hpda::internal::processor_with_input< InputObjType > | inline |
reset_done_value() (defined in hpda::functor) | hpda::functor | inline |
set_engine(engine *e) (defined in hpda::functor) | hpda::functor | |
~functor() (defined in hpda::functor) | hpda::functor | virtual |
~groupby_impl() (defined in hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType >) | hpda::processor::internal::groupby_impl< InputObjType, OutputObjType, GroupByType, AggregatorType > | inlinevirtual |
~processor_base() (defined in hpda::processor::internal::processor_base< InputObjType, OutputObjType >) | hpda::processor::internal::processor_base< InputObjType, OutputObjType > | inlinevirtual |
~processor_with_input() (defined in hpda::internal::processor_with_input< InputObjType >) | hpda::internal::processor_with_input< InputObjType > | inlinevirtual |
~processor_with_output() (defined in hpda::internal::processor_with_output< OutputObjType >) | hpda::internal::processor_with_output< OutputObjType > | inlinevirtual |