prc
Data processing, ETL, streaming, transformations.
Load with: use prc
Quick example
use prc
result = prcne("value")
prn(result)Functions
Pipeline
prcne(src)
Creates a new instance. Takes src.
prcfg(pl, fn)
Performs the operation. Takes pl, fn.
prcrn(pl)
Performs the operation. Takes pl.
prcex(pl)
Executes. Takes pl.
Sources
prcsv(p)
Performs the operation. Takes p.
prcjs(p)
Performs the operation. Takes p.
prcsq(db, qy)
Performs the operation. Takes db, qy.
prcob(ob)
Performs the operation. Takes ob.
prcng(n)
Performs the operation. Takes n.
Sinks
prcsv(dt, p)
Performs the operation. Takes dt, p.
prcjs(dt, p)
Performs the operation. Takes dt, p.
prcdb(dt, db, tb)
Performs the operation. Takes dt, db, tb.
Transformations
prcmp(fn)
Performs the operation. Takes fn.
prcfl(fn)
Performs the operation. Takes fn.
prcrd(fn, iv)
Reads data. Takes fn, iv.
prcsr(ky)
Performs the operation. Takes ky.
prcrv()
Performs the operation.
prcnq(ky)
Performs the operation. Takes ky.
Aggregations
prcgr(ky)
Performs the operation. Takes ky.
prcag(ky, ag)
Performs the operation. Takes ky, ag.
prccn()
Performs the operation.
prcsm(fld)
Performs the operation. Takes fld.
prcav(fld)
Performs the operation. Takes fld.
prcmx(fld)
Performs the operation. Takes fld.
prcmn(fld)
Performs the operation. Takes fld.
Joins
prcjn(l, r, lk, rk)
Performs the operation. Takes l, r, lk, rk.
prclj(l, r, lk, rk)
Performs the operation. Takes l, r, lk, rk.
Streaming
prcst(fn)
Sets a value or starts a process. Takes fn.
prcps(st, it)
Performs the operation. Takes st, it.
prcf0(st)
Performs the operation. Takes st.
Windowing
prcwn(dt, sz, st)
Performs the operation. Takes dt, sz, st.
Validation
prcvd(sc)
Performs the operation. Takes sc.
prcrq()
Performs the operation.
prcnm()
Performs the operation.
prcnt()
Performs the operation.
prcrg(mn, mx)
Performs the operation. Takes mn, mx.
prcpt(p)
Performs the operation. Takes p.
Notes
- Process management - spawn, kill, IPC.