summaryrefslogtreecommitdiff
path: root/internal/mapr/globalgroupset.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-03-10 20:01:15 +0200
committerPaul Buetow <paul@buetow.org>2026-03-10 20:01:15 +0200
commit71e431af2e65196ad4e7bc3404e772b1726d3338 (patch)
tree935e3b1af7c5b0033caf13ea00cf9655686b6ec9 /internal/mapr/globalgroupset.go
parentf6e23930da2900c43a5389a2e7d1e38d8221a76f (diff)
Introduce client runtime boundaries
Diffstat (limited to 'internal/mapr/globalgroupset.go')
-rw-r--r--internal/mapr/globalgroupset.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/mapr/globalgroupset.go b/internal/mapr/globalgroupset.go
index 2b12898..4f1e5ba 100644
--- a/internal/mapr/globalgroupset.go
+++ b/internal/mapr/globalgroupset.go
@@ -86,8 +86,8 @@ func (g *GlobalGroupSet) WriteResult(query *Query, finalResult bool) error {
}
// Result returns the result of the mapreduce aggregation as a string.
-func (g *GlobalGroupSet) Result(query *Query, rowsLimit int) (string, int, error) {
+func (g *GlobalGroupSet) Result(query *Query, rowsLimit int, renderer ResultRenderer) (string, int, error) {
g.semaphore <- struct{}{}
defer func() { <-g.semaphore }()
- return g.GroupSet.Result(query, rowsLimit)
+ return g.GroupSet.Result(query, rowsLimit, renderer)
}