public class LogAnalytics
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool
LogManager
, and calculates the aggregate daily pageviews. The
output of the job is stored in a Gora compatible data store.
See the tutorial.html file in docs or go to the web sitefor more information.
Modifier and Type | Class and Description |
---|---|
static class |
LogAnalytics.LogAnalyticsMapper
The Mapper takes Long keys and Pageview objects, and emits
tuples of <url, day> as keys and 1 as values.
|
static class |
LogAnalytics.LogAnalyticsReducer
The Reducer receives tuples of <url, day> as keys and a list of
values corresponding to the keys, and emits a combined keys and
MetricDatum objects. |
Constructor and Description |
---|
LogAnalytics() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.Job |
createJob(DataStore<Long,Pageview> inStore,
DataStore<String,MetricDatum> outStore,
int numReducer)
Creates and returns the
Job for submitting to Hadoop mapreduce. |
static void |
main(String[] args) |
int |
run(String[] args) |
public org.apache.hadoop.mapreduce.Job createJob(DataStore<Long,Pageview> inStore, DataStore<String,MetricDatum> outStore, int numReducer) throws IOException
Job
for submitting to Hadoop mapreduce.inStore
- outStore
- numReducer
- IOException
public int run(String[] args) throws Exception
run
in interface org.apache.hadoop.util.Tool
Exception
Copyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.