rethinkdb - early query - simple

distinct.rql.js

r.db('joola').table('reads').filter(r.row('timestamp').during(r.time(2010,1,1,'Z'), r.time(2015,1,1,'Z'))).group('workspace', 'username').sum('readCount');

insert_login.js

joola.insert('logins', [{userid: '123', username: 'itay', attempts: 1, success: true}, {userid: '1234', username: 'or', attempts: 2, success: true}]);

insert_visit.js

joola.insert('visits', [{userid: '123', username: 'itay', device: 'android', visits: 1}, {userid: '1234', username: 'or', device: 'iphone', visits: 2}, {userid: '123', username: 'itay', device: 'iphone', visits: 1}]);

query.js

joola.fetch({
  dimensions: ['username', 'device'],
  metrics: [
    'visits',
    {
      key: 'login_attempts',
      dependsOn: 'attempts',
      collection: 'logins'
    },
    {
      key: 'avg_visits',
      dependsOn: 'visits',
      collection: 'visits',
      aggregation: 'avg'
    },
    {
      key: 'unique_users',
      dependsOn: 'userid',
      aggregation: 'ucount'
    }
  ],
  collection: 'visits',
  filter: [
    ['username', 'eq', 'itay']
  ]
})

sum_avg.rql.js

var sort = function(){
  return null;
  //return r.asc('Id');
};
var filter = function(doc){
  return {}; //doc('attribute').eq('test3');
};
var group = function(){
  return 'attribute';
};
var map = function(doc){
  return {
    attribute: doc('attribute'), 
    value: doc('value'), 
    max_value: doc('value'),
    sum_value: doc('value'), 
    doccount: 1
  };
};
var reduce = function(left, right){
  return {
    attribute: left('attribute'),
    sum_value: left('sum_value').add(right('sum_value')),
    max_value: r.branch(left('max_value').gt(right('max_value')), left('max_value'), right('max_value')),
    doccount: left('doccount').add(right('doccount'))
  };
};
var final = function(doc){
  return {
    attribute: doc('reduction')('attribute'), 
    sum_value: doc('reduction')('sum_value'), 
    avg_value: doc('reduction')('sum_value').div(doc('reduction')('doccount')),
    max_value: doc('reduction')('max_value')
  }
};
r.db('joola').table('testforor').filter(filter).map(map).group(group()).reduce(reduce).ungroup().map(final);

timeseries.js

joola.fetch({
  timeframe: 'last_30_days',
  interval: 'day',
  dimensions: ['timestamp'],
  metrics: [
    'visits'
  ],
  collection: 'visits',
filter:[['username','eq','itay']]
})