106 lines
4.2 KiB
Plaintext
106 lines
4.2 KiB
Plaintext
|
Database: opt
|
||
|
|
Restore : NO
|
||
|
|
|
||
|
|
Operator: doubleexport
|
||
|
|
Number: 1
|
||
|
|
Signature: ((stream (tuple((a1 t1) ... (ai ti) ... (an tm)))) (stream (tuple((b1 p1) ... (bj tj) ... (bm tm)))) ai bj)-> ((stream (tuple (key:text) (value:text))))
|
||
|
|
Example: query plz feed head[5] {p} Orte feed head[3] {o} doubleexport[Ort_p, Ort_o] count
|
||
|
|
Result: 8
|
||
|
|
|
||
|
|
Operator: parahashjoin
|
||
|
|
Number: 1
|
||
|
|
Signature: ( (stream (tuple((v: text)))) text text ) -> stream(tuple(...))
|
||
|
|
Example: query plz feed {p} Orte feed {o} doubleexport[Ort_p, Ort_o] sortby[KeyT] add0Tuple project[ValueT] plz Orte parahashjoin count;
|
||
|
|
Result: 10052
|
||
|
|
|
||
|
|
Operator: TUPSTREAM
|
||
|
|
Number: 1
|
||
|
|
Signature: ( (rel(T1)) ... ) -> stream(T1)
|
||
|
|
Example: query plz feed {p} Orte feed {o} doubleexport[Ort_p, Ort_o] sortby[KeyT] add0Tuple project[ValueT] plz Orte parajoin[. {p} .. {o} product] count;
|
||
|
|
Result: 10052
|
||
|
|
|
||
|
|
Operator: TUPSTREAM2
|
||
|
|
Number: 1
|
||
|
|
Signature: ( T1 (rel(T2)) ... ) -> stream(T2)
|
||
|
|
Example: query plz feed {p} Orte feed {o} doubleexport[Ort_p, Ort_o] sortby[KeyT] add0Tuple project[ValueT] plz Orte parajoin[. {p} .. {o} product] count;
|
||
|
|
Result: 10052
|
||
|
|
|
||
|
|
Operator: TUPSTREAM3
|
||
|
|
Number: 1
|
||
|
|
Signature: ( T1 T2 (rel(T3)) ... ) -> stream(T3)
|
||
|
|
Example: query plz feed {p} Orte feed {o} doubleexport[Ort_p, Ort_o] sortby[KeyT] add0Tuple project[ValueT] plz Orte parajoin[. {p} .. {o} product] count;
|
||
|
|
Result: 10052
|
||
|
|
|
||
|
|
Operator: parajoin
|
||
|
|
Number: 1
|
||
|
|
Signature: ( (stream(tuple((v: text)))) x (rel(tuple(T1))) x (rel(tuple(T2))) x ((map (stream(T1)) (stream(T2)) (stream(T1 T2)))))) -> stream(tuple(T1 T2))
|
||
|
|
Example: query plz feed {p} Orte feed {o} doubleexport[Ort_p, Ort_o] sortby[KeyT] add0Tuple project[ValueT] plz Orte parajoin[. {p} .. {o} product] count;
|
||
|
|
Result: 10052
|
||
|
|
|
||
|
|
|
||
|
|
Operator: add0Tuple
|
||
|
|
Number: 1
|
||
|
|
Signature: (stream(tuple((KeyT string)(ValueT text)))) -> stream(tuple((KeyT string)(ValueT text)))
|
||
|
|
Example: query plz feed head[5] {p} Orte feed head[3] {o} doubleexport[Ort_p, Ort_o] sortby[KeyT] add0Tuple count;
|
||
|
|
Result: 11
|
||
|
|
|
||
|
|
Operator : fconsume
|
||
|
|
Number : 1
|
||
|
|
Signature: stream(tuple(...)) x string x text x [int] x [int] x [ [int] x [int] ] x [ int x int ] -> bool
|
||
|
|
Example : query plz feed fconsume["plzComp", '', 1;;]
|
||
|
|
Result : TRUE
|
||
|
|
|
||
|
|
Operator : ffeed
|
||
|
|
Number : 1
|
||
|
|
Signature: string x string x [int] x [int] x [int x int x int] -> stream(tuple(...))
|
||
|
|
Example : query "plzComp" ffeed['',1;;] count
|
||
|
|
Result : 41267
|
||
|
|
|
||
|
|
Operator : ffeed2
|
||
|
|
Number : 1
|
||
|
|
Signature: string x string x [int] x [int] x [int x int x int] -> stream(tuple(...))
|
||
|
|
Example : query "plzComp" ffeed2['',1;;] count
|
||
|
|
Result : 41267
|
||
|
|
|
||
|
|
Operator : hadoopjoin
|
||
|
|
Number : 1
|
||
|
|
Signature: ((stream(tuple(T1))) x (stream(tuple(T2))) x array(string) x int x int x (map stream(tuple(T1)) stream(tuple(T2)) stream(tuple(T1 T2)))) -> stream(tuple((mIndex int)(pIndex int)))
|
||
|
|
Example : query plz feed Orte feed {rr} hadoopjoin[ Ort, Ort_rr, 20, "Result";; . .. hashjoin[Ort, Ort_rr, 99997] ] getTypeNL
|
||
|
|
Result : '(stream (tuple ((MIndex int) (PIndex int))))'
|
||
|
|
|
||
|
|
Operator : fdistribute
|
||
|
|
Number : 1
|
||
|
|
Signature: stream(tuple((a1 t1) ... (ai ti) ... (an tm))) x string x text x ai x int -> stream(tuple((sufix int) (ai ti)))
|
||
|
|
Example : query plz feed fdistribute["plz_dis", '', PLZ; 50, TRUE; ; ] loopsel["plz_dis" ffeed['',.Suffix; ; ]] count
|
||
|
|
Result : 41267
|
||
|
|
|
||
|
|
Operator : fconsume3
|
||
|
|
Number : 1
|
||
|
|
Signature: stream(tuple(...)) x string x text x [int] x [int] x [ [int] x [int] ] x [ int x int ] -> bool
|
||
|
|
Example : query plz feed extend[Ext: 'ExtendedText'] fconsume3["plzComp3", '', 1;;]
|
||
|
|
Result : TRUE
|
||
|
|
|
||
|
|
Operator : ffeed3
|
||
|
|
Number : 1
|
||
|
|
Signature: string x string x [int] x [int] x [int x int x int] -> stream(tuple(...))
|
||
|
|
Example : query "plzComp3" ffeed3['',1;;] count
|
||
|
|
Result : 41267
|
||
|
|
|
||
|
|
Operator : fetchFlob
|
||
|
|
Number : 1
|
||
|
|
Signature: stream(tuple(T, DS_IDX)) x [T] -> stream(tuple(T))
|
||
|
|
Example : query "plzComp3" ffeed3['',1;;] fetchFlob[] count
|
||
|
|
Result : 41267
|
||
|
|
|
||
|
|
Operator : fdistribute3
|
||
|
|
Number : 1
|
||
|
|
Signature: stream(tuple((a1 t1) ... (ai ti) ... (an tm))) x string x text x ai x int -> stream(tuple((sufix int) (ai ti)))
|
||
|
|
Example : query plz feed fdistribute3["plz_dis", '', PLZ; 50, TRUE; ; ] loopsel["plz_dis" ffeed['',.Suffix; ; ]] count
|
||
|
|
Result : 41267
|
||
|
|
|
||
|
|
Operator : genFlobResult
|
||
|
|
Number : 1
|
||
|
|
Signature: int x string x string -> bool
|
||
|
|
Example : query genFlobResult(0, "exampleSheet", "exampleResult")
|
||
|
|
Result : crashes
|