blob: 876648b6c363f35ba3d5c207811b32020a251c01 [file] [log] [blame]
vinayakb38b7ca42012-03-05 05:44:15 +00001drop dataverse test if exists;
2create dataverse test;
3use dataverse test;
4
5create type UserType as open {
6 uid: int32,
7 name: string,
8 lottery_numbers: [int32],
9 interests: {{string}}
10}
11
12create type VisitorType as open {
13 vid: int32,
14 name: string,
15 lottery_numbers: [int32],
16 interests: {{string}}
17}
18
19create nodegroup group1 if not exists on nc1, nc2;
20
21create dataset Users(UserType) partitioned by key uid on group1;
22create dataset Visitors(VisitorType) partitioned by key vid on group1;
23
24
25load dataset Users
26using "edu.uci.ics.asterix.external.dataset.adapter.NCFileSystemAdapter"
27(("path"="nc1://data/users-visitors-small/users.json"),("format"="adm"));
28
29load dataset Visitors
30using "edu.uci.ics.asterix.external.dataset.adapter.NCFileSystemAdapter"
31(("path"="nc1://data/users-visitors-small/visitors.json"),("format"="adm"));
32
33write output to nc1:'rttest/nested-loop-join_01.adm';
34
35for $user in dataset('Users')
36for $visitor in dataset('Visitors')
37where len($user.lottery_numbers) = len($visitor.lottery_numbers)
38order by $user.uid, $visitor.vid
39return {'user': $user, 'visitor': $visitor, 'user-lottery_numbers-len': len($user.lottery_numbers), 'visitor-lottery_numbers-len': len($visitor.lottery_numbers)}