Redis Input

Description

Redis Input enriches each incoming pipeline row by reading one or more Redis values using a shared Redis Connection.

Configure a fields table: each row is one mapping that adds an output column to the same pipeline row. This transform needs upstream rows that supply Redis keys (or you can use literal / variable keys in the table).

Supported operations:

Data structure Command Value field content

Data structure	Command	Value field content
STRING	`GET`	Decoded scalar value (or null if missing)
HASH	`HGET`	Decoded hash value (Hash field is required). `HGETALL` is not supported.
SET	`SMEMBERS`	JSON array string of decoded members, e.g. `["a","b"]` (empty set → `[]`)
LIST	`LRANGE`	JSON array string of decoded elements for the configured range (empty → `[]`)

STRING

GET

Decoded scalar value (or null if missing)

HASH

HGET

Decoded hash value (Hash field is required). HGETALL is not supported.

SET

SMEMBERS

JSON array string of decoded members, e.g. ["a","b"] (empty set → [])

LIST

LRANGE

JSON array string of decoded elements for the configured range (empty → [])

SISMEMBER is not supported.

Redis key and hash field resolution

Redis key and Hash field are editable combo boxes: pick an upstream field name or type a value.

If the text matches an incoming stream field name, Redis uses that field’s value from the current row.
Otherwise the text is treated as a literal (variables such as ${PREFIX}:user are resolved).

Options

Option Description

Option	Description
Redis connection	Name of the Redis connection metadata
Fields table	One or more read mappings (see below). Use Get fields to add one mapping per upstream field (defaults: data structure `STRING`, Redis key = field name, value field = `{fieldName}Value`, codecs `STRING`, hash columns empty, list start/stop `0` / `-1`).

Redis connection

Name of the Redis connection metadata

Fields table

One or more read mappings (see below). Use Get fields to add one mapping per upstream field (defaults: data structure STRING, Redis key = field name, value field = {fieldName}Value, codecs STRING, hash columns empty, list start/stop 0 / -1).

Fields table columns

Column Description

Column	Description
Redis key	Stream field name (use that field’s value) or literal / variable — see Redis key and hash field resolution
Redis key codec	Encoding for the Redis key
Data structure	`STRING`, `HASH`, `SET`, or `LIST`
Hash field	Required for `HASH` (`HGET`). Stream field name or literal. Ignored otherwise.
Hash field codec	Encoding for the hash field name (`HASH` only)
Value field	Name of the output column added to the stream
Value codec	Encoding for STRING/HASH values, and for each SET/LIST element before building the JSON array
List start / List stop	`LRANGE` bounds (default `0` / `-1`). Use the same index twice (e.g. `5` / `5`) to read a single element as a one-item array. Ignored for non-LIST rows.

Redis key

Stream field name (use that field’s value) or literal / variable — see Redis key and hash field resolution

Redis key codec

Encoding for the Redis key

Data structure

STRING, HASH, SET, or LIST

Hash field

Required for HASH (HGET). Stream field name or literal. Ignored otherwise.

Hash field codec

Encoding for the hash field name (HASH only)

Value field

Name of the output column added to the stream

Value codec

Encoding for STRING/HASH values, and for each SET/LIST element before building the JSON array

List start / List stop

LRANGE bounds (default 0 / -1). Use the same index twice (e.g. 5 / 5) to read a single element as a one-item array. Ignored for non-LIST rows.

Codecs: STRING, JSON, JAVA_OBJECT, BYTE.