co.cask.cdap.examples.loganalysis

Class LogAnalysisApp

java.lang.Object

co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable

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

co.cask.cdap.api.app.AbstractApplication

co.cask.cdap.examples.loganalysis.LogAnalysisApp

All Implemented Interfaces:

Application

public class LogAnalysisApp
extends AbstractApplication

Application that demonstrate running a Spark and MapReduce simultaneously in a Workflow

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LogAnalysisApp.HitCounterServiceHandler A Service that responds with total number of hits for a given URL or path
static class	LogAnalysisApp.LogAnalysisWorkflow A Workflow which ties spark and mapreduce program together for log analysis
static class	LogAnalysisApp.RequestCounterHandler A Service which serves the number of requests made by unique ip address from a TimePartitionedFileSet
static class	LogAnalysisApp.ResponseCounterHandler A Service that responds with total number of responses for a given response code
static class	LogAnalysisApp.ResponseCounterSpark Specification for the Spark program in this application

Field Summary

Fields

Modifier and Type	Field and Description
static String	HIT_COUNT_STORE
static String	HIT_COUNTER_SERVICE
static String	LOG_STREAM
static String	REQ_COUNT_STORE
static String	REQUEST_COUNTER_SERVICE
static String	RESPONSE_COUNT_STORE
static String	RESPONSE_COUNTER_SERVICE

Constructor Summary

Constructors

Constructor and Description
LogAnalysisApp()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure()

Methods inherited from class co.cask.cdap.api.app.AbstractApplication

addFlow, addMapReduce, addService, addService, addSpark, addWorker, addWorkflow, configure, getConfig, getConfigurer, getContext, scheduleWorkflow, scheduleWorkflow, setDescription, setName

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

Field Detail

LOG_STREAM

public static final String LOG_STREAM

See Also:

Constant Field Values

HIT_COUNTER_SERVICE

public static final String HIT_COUNTER_SERVICE

See Also:

Constant Field Values

RESPONSE_COUNTER_SERVICE

public static final String RESPONSE_COUNTER_SERVICE

See Also:

Constant Field Values

REQUEST_COUNTER_SERVICE

public static final String REQUEST_COUNTER_SERVICE

See Also:

Constant Field Values

RESPONSE_COUNT_STORE

public static final String RESPONSE_COUNT_STORE

See Also:

Constant Field Values

HIT_COUNT_STORE

public static final String HIT_COUNT_STORE

See Also:

Constant Field Values

REQ_COUNT_STORE

public static final String REQ_COUNT_STORE

See Also:

Constant Field Values

Constructor Detail

LogAnalysisApp

public LogAnalysisApp()

Method Detail

configure

public void configure()

Specified by:

configure in class AbstractApplication