search

mbilwar / jaql

Automatically exported from code.google.com/p/jaql
0 stars 0 forks source link

Embedding Jaql #98

Open GoogleCodeExporter opened 8 years ago

GoogleCodeExporter commented 8 years ago 

I want to run the follow pipe
$Pipe = read(hdfs('example'));
$Pipe -> filter $.type == "http://www.w3.org/1999/02/22-rdf-syntax-ns#type"
 -> transform {someone: $.people,type: $.type}
 -> write(hdfs('temp00'));
$Pipe -> filter $.p == "http://www.w3.org/2000/01/rdf-schema#lable"
 -> transform {someone: $.people,lable: $.lable}
 -> write(hdfs('temp01'));

$s0 = read(hdfs('temp00'));
$s1 = read(hdfs('temp01'));
join $s0,$s1 where $s0.someone == $s1.someone into {$s1.*}
 -> write(hdfs('temp'));

but when run the pipe as follow;

jaql.setQueryString("$Pipe = read(hdfs('example'));");
//run each pipe mentioned before

it return error!

My question: 

I don't know how to solve it!
Can I write all these pipe to the methord: jaql.setQueryString("all pipe")  ??

Original issue reported on code.google.com by niexue...@gmail.com on 10 Oct 2010 at 8:19