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") ??

Comment deleted