Returns ID of current microbatch attempt. Can only be called within a microbatch topology. This can be used to achieve fault-tolerant exactly-once update semantics when updating external systems with Rama’s integration API.

Returns task ID where event is running.

Emits every element of input list as a separate field. Useful for processing elements of fixed-size lists.

Example:

(ops/expand *data :> *a *b *c)

Emits once for each element of a sequence. For example:

(?<-
  (explode [1 2 3] :> *v)
  (println *v))
1
2
3
nil

Same as explode except also outputs the index of each element. For example:

(?<-
  (ops/explode-indexed [:a :b :c] :> *i *v)
  (println *i *v))
0 :a
1 :b
2 :c
nil

Like explode except emits each key/value pair as separate elements. For example:

(?<-
  (ops/explode-map {:a 1 :b 2 :c 3} :> *k *v)
  (println *k *v))
:a 1
:b 2
:c 3
nil

Returns ModuleInstanceInfo for module and worker of running event.

Like Clojure range, but emits once per element in the range.

Example:

(?<-
  (range> 10 13 :> *v)
  (println *v))
10
11
12
nil

Returns sum of values in provided sequence.

Extracts contents of a PState as a value. Should only be called on PStates with a top-level Class schema.