blob: 162dd74ef30402b9c68ff65c1fc07732c6e247f4 [file] [log] [blame]
Yingyi Bu391f09e2015-10-29 13:49:39 -07001/*
2 * Licensed to the Apache Software Foundation (ASF) under one
3 * or more contributor license agreements. See the NOTICE file
4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
6 * to you under the Apache License, Version 2.0 (the
7 * "License"); you may not use this file except in compliance
8 * with the License. You may obtain a copy of the License at
9 *
10 * http://www.apache.org/licenses/LICENSE-2.0
11 *
12 * Unless required by applicable law or agreed to in writing,
13 * software distributed under the License is distributed on an
14 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15 * KIND, either express or implied. See the License for the
16 * specific language governing permissions and limitations
17 * under the License.
18 */
19
20drop database events if exists;
21create database events;
22
23use events;
24
25
26create type events.AddressType as
27 closed {
28 street : string,
29 city : string,
30 zip : string
31}
32
33create type events.EventType as
34 closed {
35 name : string,
36 location : AddressType?,
37 organizers : {{{
38 name : string,
39 role : string
40 }
41}},
42 sponsoring_sigs : [{
43 sig_name : string,
44 chapter_name : string
45 }
46],
47 interest_keywords : {{string}},
48 price : double?,
49 start_time : datetime,
50 end_time : datetime
51}
52
53create nodegroup group1 if not exists on
54 nc1,
55 nc2
56;
57create table Event(EventType) primary key name on group1;
58
59write output to nc1:"/tmp/q2.adm"
60select element {'sig_name':sig_name,'total_count':sig_sponsorship_count,'chapter_breakdown':by_chapter}
61from Event as event,
62 event.sponsoring_sigs as sponsor
63with es as {'event':event,'sponsor':sponsor}
64group by sponsor.sig_name as sig_name
65with sig_sponsorship_count as events.count(es),
66 by_chapter as (
67 select element {'chapter_name':chapter_name,'escount':events.count(e)}
68 from es as e
69 group by e.sponsor.chapter_name as chapter_name
70 )
71order by sig_sponsorship_count desc
72limit 5
73;