bkietz commented on a change in pull request #9621:
URL: https://github.com/apache/arrow/pull/9621#discussion_r599003922
##########
File path: cpp/src/arrow/compute/api_aggregate.h
##########
@@ -306,5 +306,100 @@ Result<Datum> TDigest(const Datum& value,
const TDigestOptions& options =
TDigestOptions::Defaults(),
ExecContext* ctx = NULLPTR);
+namespace internal {
+
+/// Internal use only: streaming group identifier.
+/// Consumes batches of keys and yields batches of the group ids.
+class ARROW_EXPORT Grouper {
+ public:
+ virtual ~Grouper() = default;
+
+ /// Construct a Grouper which receives the specified key types
+ static Result<std::unique_ptr<Grouper>> Make(const std::vector<ValueDescr>&
descrs,
+ ExecContext* ctx =
default_exec_context());
+
+ /// Consume a batch of keys, producing the corresponding group ids as an
integer array.
Review comment:
Alright. Eventually we'll support multiple integer types (increasing the
width as needed)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
