stream/AggregationStream.java

Fluent API for building Redis aggregation queries with grouping, filtering, and reducing capabilities.

// Source: https://github.com/redis/redis-om-spring | License: MIT | Copyright 2021, Redis, inc
// Provided via justclaw.it.com; keep this notice with the code.
package com.redis.om.spring.search.stream;

import java.time.Duration;
import java.util.List;
import java.util.Map;

import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort.Order;

import com.redis.om.spring.annotations.ReducerFunction;
import com.redis.om.spring.metamodel.MetamodelField;
import com.redis.om.spring.search.stream.aggregations.filters.AggregationFilter;

import redis.clients.jedis.search.aggr.AggregationResult;

/**
 * A fluent API for building and executing Redis aggregation queries.
 * AggregationStream provides a chainable interface 

... (truncated -- full source via MCP)