GearsBuilder

Creates a RedisGears pipeline of operations to transform data.

The GearsBuilder class allows you to create a pipeline of RedisGears functions that transform data.

It requires a reader to supply data to the pipe.

To create a GearsBuilder object, follow this example code:

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

Functions

Function Description
accumulate Reduces many records in the pipe to a single record.
accumulateBy Groups records and reduces each group to a single record per group.
asyncFilter Asynchronously filters out records in the pipe based on a given condition.
asyncForeach For each record in the pipe, asynchronously runs some operations.
asyncMap Asynchronously maps records one-to-one.
callNext Calls the next execution that overrides the command or the original command itself. A more flexible version of callNextArray.
callNextArray Calls the next execution that overrides the command or the original command itself.
collect Collects all records to the origin shard.
configGet Gets the value of a RedisGears configuration setting.
count Counts the number of records in the pipe.
CreateGearsBuilder Creates a new GearsBuilder object.
execute Runs a Redis command. A more flexible version of executeArray.
executeArray Runs a Redis command.
filter Filters out records in the pipe based on a given condition.
flatMap Maps a single input record to one or more output records.
foreach For each record in the pipe, runs some operations.
hashtag Returns a string that maps to the current shard.
localAccumulateBy Groups records and reduces each group to a single record per group locally on each shard.
log Writes a log message to the Redis log file.
map Maps records one-to-one.
register Registers the pipeline of functions to run when certain events occur.
repartition Moves records between shards according to the extracted data.
run Runs the pipeline of functions immediately.
RATE THIS PAGE
Back to top ↑