Commit 7e563898 authored by Kai-Uwe Sattler's avatar Kai-Uwe Sattler
Browse files

cleanup in groupBy

parent 8a1678dd
...@@ -891,11 +891,9 @@ class Pipe { ...@@ -891,11 +891,9 @@ class Pipe {
* *
* // Aggregator1 defines already functions for finalize and iterate * // Aggregator1 defines already functions for finalize and iterate
* t->newStreamFrom... * t->newStreamFrom...
* .aggregate<T1, T2, MyAggrState> () * .aggregate<T2, MyAggrState> ()
* @endcode * @endcode
* *
* @tparam Tin
* the input tuple type (usually a TuplePtr) for the operator.
* @tparam Tout * @tparam Tout
* the result tuple type (usually a TuplePtr) for the operator. * the result tuple type (usually a TuplePtr) for the operator.
* @tparam AggrState * @tparam AggrState
...@@ -937,12 +935,10 @@ class Pipe { ...@@ -937,12 +935,10 @@ class Pipe {
* *
* // Aggregator1 defines already functions for finalize and iterate * // Aggregator1 defines already functions for finalize and iterate
* t->newStreamFrom... * t->newStreamFrom...
* .aggregate<T1, T2, MyAggrState> (MyAggrState::finalize, * .aggregate<T2, MyAggrState> (MyAggrState::finalize,
* MyAggrState::iterate) * MyAggrState::iterate)
* @endcode * @endcode
* *
* @tparam Tin
* the input tuple type (usually a TuplePtr) for the operator.
* @tparam Tout * @tparam Tout
* the result tuple type (usually a TuplePtr) for the operator. * the result tuple type (usually a TuplePtr) for the operator.
* @tparam AggrState * @tparam AggrState
......
...@@ -20,7 +20,7 @@ using namespace ns_types; ...@@ -20,7 +20,7 @@ using namespace ns_types;
TEST_CASE("Building and running a topology with standard grouping", "[GroupBy]") { TEST_CASE("Building and running a topology with standard grouping", "[GroupBy]") {
typedef TuplePtr<Tuple<std::string, int>> MyTuplePtr; typedef TuplePtr<Tuple<std::string, int>> MyTuplePtr;
typedef TuplePtr<Tuple<std::string, int>> AggrRes; typedef TuplePtr<Tuple<std::string, int>> AggrRes;
typedef Aggregator2<AggrRes, AggrIdentity<std::string>, 0, AggrCount<int, int>, 1> AggrState; typedef Aggregator2<MyTuplePtr, AggrIdentity<std::string>, 0, AggrCount<int, int>, 1> AggrState;
std::map<std::string, int> results; std::map<std::string, int> results;
Topology t; Topology t;
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment