Skip to content

Latest commit

 

History

History
55 lines (40 loc) · 2.9 KB

File metadata and controls

55 lines (40 loc) · 2.9 KB

Operator Reference

Auto-generated from Go operator source code. Do not edit manually.

Filter

Operator Description
filter_condition Removes items where a specified field equals a given value.
filter_paginate Keeps only items in the [pagesize, pagesize+size) range, removes the rest.
filter_truncate Keeps only the first N items, removing the rest.

Merge

Operator Description
merge_dedup Deduplicates items by a key field, keeping the first occurrence.

Observe

Operator Description
observe_log Reads declared input fields and writes them to the engine's logger. This is a read-only operator: it produces no output fields and does not modify the DataFrame. It is exempt from dead-code detection.

Recall

Operator Description
recall_resource Recalls items from a named resource.
recall_static Emits a configurable static set of items for testing and validation.

Reorder

Operator Description
reorder_shuffle_by_salt Deterministic hash-based shuffle using a caller-provided salt.
reorder_sort Sorts items by a numeric field in ascending or descending order.

Transform

Operator Description
transform_bench_cpu Benchmark-only CPU-bound operator. Computes iterative fib per item. Not available in pine-python.
transform_bench_sleep Benchmark-only I/O-simulating operator. Sleeps for delay_ms per invocation. Not available in pine-python.
transform_by_lua Executes a Lua script for per-item or per-common computation.
transform_by_remote_pineapple Calls a downstream Pineapple service and maps response fields back to the local frame.
transform_copy Copies field values between common and item dimensions.
transform_dispatch Copies a common-side field value to every item as an item-side field.
transform_normalize Normalizes a numeric item field using min-max scaling to [0, 1].
transform_redis_get Generic Redis read operator. Reads a value by key and outputs the result and a cache-hit flag.
transform_redis_set Generic Redis write operator. Writes a value by key with optional TTL.
transform_resource_lookup Enriches items by looking up values from a named resource.
transform_size Outputs the current item count to a common field.