Processors

Processor nodes reside in the middle of a Juttle flowgraph, modifying streams as they pass through.

(source; source) | processor | (processor; processor) | processor | (sink; sink)

Example modifications include transforming, reducing, and filtering.

batch

Create batches by segmenting a sequence of points ordered by time stamp, each segment spanning a specified interval of time.

filter

Output only the points for which the given filtering expression evaluates to true.

head

Only emit the first limit points from each batch.

join

Create new points from the points of multiple input streams.

keep

Prune the input stream by removing all fields except the specified ones.

pace

Play back historic points in real time or at the specified pace.

put

Set the specified field of each point to the result of an expression.

reduce

Accumulate collections of points and aggregate them using reducers, optionally within a moving time window.

remove

Prune the input stream by removing the specified fields.

sort

Sort points in order based on values of one or more specified fields.

split

Split each incoming point, emitting one new point for each of the specified fields in the original point.

tail

Only emit the last limit points from each batch.

unbatch

Turn a batched stream into an unbatched stream.

uniq

Compare adjacent points and discard any duplicates.