GearsBuilder

创建 RedisGears 操作管道以转换数据。

GearsBuilder 类允许您创建转换数据的 RedisGears 函数管道。

它需要一个读取器来为管道提供数据。

要创建 GearsBuilder 对象，请按照以下示例代码操作

BaseReader reader = ...; // Initialize the reader
builder = GearsBuilder.CreateGearsBuilder(reader);

函数

函数	描述
accumulate	将管道中的许多记录减少到单个记录。
accumulateBy	对记录进行分组并将每个组减少为每个组的单个记录。
asyncFilter	根据给定的条件异步过滤掉管道中的记录。
asyncForeach	对于管道中的每个记录，异步运行一些操作。
asyncMap	异步地一对一映射记录。
callNext	调用下一个执行，它会覆盖命令或原始命令本身。一个更灵活的 callNextArray 版本。
callNextArray	调用下一个执行，它会覆盖命令或原始命令本身。
collect	将所有记录收集到原始分片。
configGet	获取 RedisGears 配置设置的值。
count	计算管道中记录的数量。
CreateGearsBuilder	创建一个新的 GearsBuilder 对象。
execute	运行 Redis 命令。一个更灵活的 executeArray 版本。
executeArray	运行 Redis 命令。
filter	根据给定的条件过滤掉管道中的记录。
flatMap	将单个输入记录映射到一个或多个输出记录。
foreach	对于管道中的每个记录，运行一些操作。
hashtag	返回一个映射到当前分片的字符串。
localAccumulateBy	对记录进行分组并将每个组减少为每个分片本地的单个记录。
log	将日志消息写入 Redis 日志文件。
map	一对一映射记录。
register	注册函数管道以在某些事件发生时运行。
repartition	根据提取的数据在分片之间移动记录。
run	立即运行函数管道。