co.cask.cdap.examples.loganalysis

Class HitCounterProgram

java.lang.Object

co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable

co.cask.cdap.internal.api.AbstractPluginConfigurable<MapReduceConfigurer>

co.cask.cdap.api.mapreduce.AbstractMapReduce

co.cask.cdap.examples.loganalysis.HitCounterProgram

All Implemented Interfaces:

MapReduce, ProgramLifecycle<MapReduceContext>

public class HitCounterProgram
extends AbstractMapReduce

A MapReduce job which computes total number of hits for every unique url or path in apache access logs

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HitCounterProgram.Counter A reducer that sums up the counts for each key.
static class	HitCounterProgram.Emitter A mapper that emits each url or path with a value of 1.

Constructor Summary

Constructors

Constructor and Description
HitCounterProgram()

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize()

Methods inherited from class co.cask.cdap.api.mapreduce.AbstractMapReduce

beforeSubmit, configure, configure, destroy, getConfigurer, getContext, initialize, onFinish, setDescription, setDriverResources, setInputDataset, setMapperResources, setName, setProperties, setReducerResources, useStreamInput, useStreamInput, useStreamInput

Methods inherited from class co.cask.cdap.internal.api.AbstractPluginConfigurable

usePlugin, usePlugin, usePluginClass, usePluginClass

Methods inherited from class co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable

addDatasetModule, addDatasetType, addStream, addStream, createDataset, createDataset, createDataset, createDataset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HitCounterProgram

public HitCounterProgram()

Method Detail

initialize

public void initialize()
                throws Exception

Overrides:

initialize in class AbstractMapReduce

Throws:

Exception