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.
Create batches by segmenting a sequence of points ordered by time stamp, each segment spanning a specified interval of time.
Output only the points for which the given filtering expression evaluates to true.
Only emit the first limit points from each batch.
Create new points from the points of multiple input streams.
Prune the input stream by removing all fields except the specified ones.
Play back historic points in real time or at the specified pace.
Set the specified field of each point to the result of an expression.
Accumulate collections of points and aggregate them using reducers, optionally within a moving time window.
Prune the input stream by removing the specified fields.
Sort points in order based on values of one or more specified fields.
Split each incoming point, emitting one new point for each of the specified fields in the original point.
Only emit the last limit points from each batch.
Turn a batched stream into an unbatched stream.
Compare adjacent points and discard any duplicates.