Transformations
Small, typed workers that reshape data inside a pipeline without you having to write custom logic. Use them to inject constants, convert types, throttle streams, or fan-out and fan-in between components.
Uncategorized
Flatten
Transformation
# Log Message Receives a stream of messages and prints them to
Constant
Transformation
# Constant Emits a fixed, predefined value into the pipeline on
Filter
Transformation
Repeat
Transformation
Unpack Tuple
Transformation
# Unpack tuple Splits a tuple into its individual components, p
List Length
Transformation
# Length Returns the number of elements in a list. ## Use this
Unpack Record
Transformation
# Unpack record Extracts each field from a record and emits it
Pack Named
Transformation
# Pack named Wraps a structured value into its corresponding na
Convert Value
Transformation
# Convert value Converts one atomic type to another, following
Unite Streams
Transformation
# Unite streams Merges multiple input streams of the same type
Delay By One
Transformation
# Delay by one Delays a stream by one message, emitting a user-
Lift Reroll
Transformation
# Lift reroll Collects streamed elements into lists of dynamica
Lift Unroll
Transformation
# Lift unroll Outputs the length of a list, followed by each of
Pack Record
Transformation
# Pack record Combines multiple individual streams into a singl
Pack Tuple
Transformation
# Pack tuple Combines multiple individual streams into a single
Pack Union
Transformation
# Pack union Combines multiple input streams into a single unio
Select Stream
Transformation
# Select stream Selects one stream from multiple input streams
Shuffle
Transformation
# Shuffle Groups incoming pairs by key, emitting each key toget
Unpack Named
Transformation
# Unpack named Reveals the underlying structure of a named type
Unpack Union
Transformation
# Unpack union Splits a union-typed stream into separate output