blob: abfd19715ea1c1b0d54c8c64522ea69c60309e33 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
/*
* Description : Self-equi joins on a dataset using two fields - countA and countB.
* TweetMessages has a secondary btree index on countB, and given the 'indexnl' hint
* we expect the join to be transformed into an indexed nested-loop join.
* Success : Yes
*/
drop dataverse test if exists;
create dataverse test;
use dataverse test;
create type TwitterUserType as closed {
screen-name: string,
lang: string,
friends-count: int64,
statuses-count: int64,
name: string,
followers-count: int64
}
create type TweetMessageType as closed {
tweetid: int64,
user: TwitterUserType,
sender-location: point,
send-time: datetime,
referred-topics: {{ string }},
message-text: string,
countA: int64,
countB: int64
}
create dataset TweetMessages(TweetMessageType)
primary key tweetid;
create index twmSndLocIx on TweetMessages(sender-location) type rtree;
create index msgCountAIx on TweetMessages(countA) type btree;
create index msgCountBIx on TweetMessages(countB) type btree;
create index msgTextIx on TweetMessages(message-text) type keyword;
write output to asterix_nc1:"rttest/btree-index-join_self-secondary-equi-join.adm";
for $t1 in dataset('TweetMessages')
for $t2 in dataset('TweetMessages')
let $c := $t1.countA + 20
where $c /* +indexnl */= $t2.countB
order by $t2.tweetid
return {"tweetid2": $t2.tweetid, "count2":$t2.countB};