Rama 0.26.0
Installation
To install, add the following dependency to your project or build file:
[com.rpl/rama "0.26.0"]
Namespaces
com.rpl.rama
Public variables and functions:
- +compound
- +group-by
- <<atomic
- <<batch
- <<branch
- <<cond
- <<do
- <<if
- <<query-topology
- <<ramafn
- <<ramaop
- <<shadowif
- <<sources
- <<subsource
- <<switch
- <<with-substitutions
- ?<-
- accumulator
- ack-return>
- anchor>
- anchorvar?
- and>
- anon-ramavar?
- anyvar?
- assert!
- batch<-
- block>
- case>
- close!
- combiner
- compiled-foreign-proxy
- compiled-foreign-proxy-async
- compiled-foreign-select
- compiled-foreign-select-async
- compiled-foreign-select-one
- compiled-foreign-select-one-async
- completable-future>
- continue>
- declare-depot
- declare-depot*
- declare-object
- declare-object*
- declare-pstate
- declare-pstate*
- declare-tick-depot
- declare-tick-depot*
- declared-object-task-global
- default>
- defbasicblocksegmacro
- defbasicsegmacro
- defblock
- defdepotpartitioner
- defgenerator
- defmodule
- defoperation
- deframafn
- deframaop
- depot-partition-append!
- else>
- filter>
- fixed-key-additions
- fixed-key-removals
- fixed-keys-schema
- foreign-append!
- foreign-append-async!
- foreign-depot
- foreign-depot-partition-info
- foreign-depot-partition-info-async
- foreign-depot-read
- foreign-depot-read-async
- foreign-invoke-query
- foreign-invoke-query-async
- foreign-object-info
- foreign-proxy
- foreign-proxy-async
- foreign-pstate
- foreign-query
- foreign-select
- foreign-select-async
- foreign-select-one
- foreign-select-one-async
- fragvar?
- gen-anchorvar
- gen-anyvar
- gen-anyvars
- gen-fragvar
- gen-pstatevar
- gen>
- generator
- get-module-name
- get-module-status
- hash-by
- hook>
- if>
- ifexpr
- invoke-query
- java-block<-
- java-macro!
- local-clear>
- local-select>
- local-transform>
- loop<-
- map-schema
- materialize>
- microbatch-topology
- migrate-to-subindexed
- migrated
- mirror-depot
- mirror-depot*
- mirror-pstate
- mirror-pstate*
- mirror-query
- mirror-query*
- module
- NONE>
- offset-after-timestamp-millis
- offset-ago
- open-cluster-manager
- open-cluster-manager-internal
- or>
- path>
- pobject-task-global
- proxy-status
- pstatevar?
- query-topology-task-global
- ramafn>
- ramavar?
- recur>
- seg#
- select>
- set-schema
- source-segments-as-data
- source>
- stream-topology
- this-module-pobject-task-global
- this-module-query-topology-task-global
- throw!
- unify>
- value-schema
- vector-schema
- yield-if-overtime
- |all
- |all$$
- |custom
- |custom$$
- |direct
- |direct$$
- |global
- |global$$
- |hash
- |hash$$
- |origin
- |path$$
- |shuffle
com.rpl.rama.path
Public variables and functions:
- AFTER-ELEM
- ALL
- ATOM
- BEFORE-ELEM
- before-index
- BEGINNING
- collect
- collect-one
- collected?
- comp-navs
- comp-paths
- cond-path
- continue-then-stay
- continuous-subseqs
- declarepath
- defcollector
- defdynamicnav
- defnav
- defprotocolpath
- defrichnav
- DISPENSE
- dynamic-param?
- eachnav
- END
- extend-protocolpath
- filterer
- FIRST
- if-path
- index-nav
- INDEXED-VALS
- indexed-vals
- keypath
- LAST
- late-bound
- late-path
- late-resolved-fn
- local-declarepath
- map-key
- MAP-KEYS
- MAP-VALS
- multi-path
- multi-transform
- multi-transformed
- must
- NAME
- NAMESPACE
- NIL->LIST
- NIL->SET
- nil->val
- NIL->VECTOR
- NONE
- NONE->val
- NONE-ELEM
- NONE?
- not-selected?
- nthpath
- parser
- path
- pred
- pred<
- pred<=
- pred=
- pred>
- pred>=
- providepath
- putval
- recursive-path
- select
- select-any
- select-first
- select-one
- select-one!
- selected-any?
- selected?
- set-elem
- setval
- sorted-map-range
- sorted-map-range-from
- sorted-map-range-from-start
- sorted-map-range-to
- sorted-map-range-to-end
- sorted-set-range
- sorted-set-range-from
- sorted-set-range-from-start
- sorted-set-range-to
- sorted-set-range-to-end
- srange
- srange-dynamic
- STAY
- STOP
- submap
- subselect
- subset
- term
- termval
- transform
- transformed
- traverse
- traverse-all
- VAL
- view
- with-fresh-collected
- with-page-size