search

catap / jaql

Jaql is a query language designed for Javascript Object Notation (JSON), a data format that has become popular because of its simplicity and modeling flexibility. Jaql is primarily used to analyze large-scale semi-structured data. Core features include user extensibility and parallelism. In addition to modeling semi-structured data, JSON simplifies extensibility. Hadoop's Map-Reduce is used for parallelism.
2 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