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	立即运行函数管道。