blob: c3cb9bf1de2198b0f7eb29d17b5155c976f54fdc [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.
*/
drop dataverse TinySocial if exists;
create dataverse TinySocial;
use dataverse TinySocial;
create type TwitterUserType as open {
screen-name: string,
lang: string,
friends_count: int64,
statuses_count: int64,
name: string,
followers_count: int64
}
create type TweetMessageType as closed {
tweetid: string,
user: TwitterUserType,
sender-location: point?,
send-time: datetime,
referred-topics: {{ string }},
message-text: string
}
create dataset TweetMessages(TweetMessageType)
primary key tweetid;
for $t in dataset TweetMessages
group by $d:= get-hour($t.send-time) with $t
return { "hour": $d,
"count": count($t),
"finer": for $k in $t
group by $min:= get-minute($k.create_at) with $k
order by $min
return { "minute": $min, "sum": count($k)}
}