blob: 9427ab55e903946e2c6f4bd68243382a837afee4 [file] [log] [blame]
vinayakb38b7ca42012-03-05 05:44:15 +00001drop dataverse fuzzyjoin if exists;
2create dataverse fuzzyjoin;
3use dataverse fuzzyjoin;
4
5create type TOKENSRANKEDADMType as closed {
6 token: int32,
7 rank: int32
8}
9
10create nodegroup group1 if not exists on nc1, nc2;
11
12create dataset TOKENSRANKEDADM(TOKENSRANKEDADMType) partitioned by key rank on group1;
13
14write output to nc1:'rttest/introhashpartitionmerge.adm';
15
16 for $token1 in dataset('TOKENSRANKEDADM')
17 for $token2 in
18 for $tokenRanked in dataset('TOKENSRANKEDADM')
19 order by $tokenRanked.rank
20 return $tokenRanked
21 where $token1.token = $token2.token
22 order by $token2.rank
23 return $token2.rank