A C G H I L M P R S T

A

ApacheAccessLog - Class in co.cask.cdap.examples.loganalysis

This class represents an Apache access log line.

C

centers(HttpServiceRequest, HttpServiceResponder, Integer) - Method in class co.cask.cdap.examples.loganalysis.LogAnalysisApp.ResponseCounterHandler

co.cask.cdap.examples.loganalysis - package co.cask.cdap.examples.loganalysis

configure() - Method in class co.cask.cdap.examples.loganalysis.LogAnalysisApp

configure() - Method in class co.cask.cdap.examples.loganalysis.LogAnalysisApp.LogAnalysisWorkflow

configure() - Method in class co.cask.cdap.examples.loganalysis.LogAnalysisApp.ResponseCounterSpark

G

getClientIdentd() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

getContentSize() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

getDateTimeString() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

getEndpoint() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

getHitCount(HttpServiceRequest, HttpServiceResponder) - Method in class co.cask.cdap.examples.loganalysis.LogAnalysisApp.HitCounterServiceHandler

getIpAddress() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

getMethod() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

getProtocol() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

getRequestFilesetContents(HttpServiceRequest, HttpServiceResponder) - Method in class co.cask.cdap.examples.loganalysis.LogAnalysisApp.RequestCounterHandler

Handler which reads all the parts files from a given partition in LogAnalysisApp.REQ_COUNT_STORE TimePartitionedFileSet and send it as a string.

getRequestFilesetPartitions(HttpServiceRequest, HttpServiceResponder) - Method in class co.cask.cdap.examples.loganalysis.LogAnalysisApp.RequestCounterHandler

Handler which lists all the different time partitions available in the LogAnalysisApp.REQ_COUNT_STORE TimePartitionedFileSet

getResponseCode() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

getUserID() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

H

HIT_COUNT_STORE - Static variable in class co.cask.cdap.examples.loganalysis.LogAnalysisApp

HIT_COUNTER_SERVICE - Static variable in class co.cask.cdap.examples.loganalysis.LogAnalysisApp

HitCounterProgram - Class in co.cask.cdap.examples.loganalysis

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

HitCounterProgram() - Constructor for class co.cask.cdap.examples.loganalysis.HitCounterProgram

HitCounterProgram.Counter - Class in co.cask.cdap.examples.loganalysis

A reducer that sums up the counts for each key.

HitCounterProgram.Counter() - Constructor for class co.cask.cdap.examples.loganalysis.HitCounterProgram.Counter

HitCounterProgram.Emitter - Class in co.cask.cdap.examples.loganalysis

A mapper that emits each url or path with a value of 1.

HitCounterProgram.Emitter() - Constructor for class co.cask.cdap.examples.loganalysis.HitCounterProgram.Emitter

I

initialize() - Method in class co.cask.cdap.examples.loganalysis.HitCounterProgram

L

LOG_STREAM - Static variable in class co.cask.cdap.examples.loganalysis.LogAnalysisApp

LogAnalysisApp - Class in co.cask.cdap.examples.loganalysis

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

LogAnalysisApp() - Constructor for class co.cask.cdap.examples.loganalysis.LogAnalysisApp

LogAnalysisApp.HitCounterServiceHandler - Class in co.cask.cdap.examples.loganalysis

A Service that responds with total number of hits for a given URL or path

LogAnalysisApp.HitCounterServiceHandler() - Constructor for class co.cask.cdap.examples.loganalysis.LogAnalysisApp.HitCounterServiceHandler

LogAnalysisApp.LogAnalysisWorkflow - Class in co.cask.cdap.examples.loganalysis

A Workflow which ties spark and mapreduce program together for log analysis

LogAnalysisApp.LogAnalysisWorkflow() - Constructor for class co.cask.cdap.examples.loganalysis.LogAnalysisApp.LogAnalysisWorkflow

LogAnalysisApp.RequestCounterHandler - Class in co.cask.cdap.examples.loganalysis

A Service which serves the number of requests made by unique ip address from a TimePartitionedFileSet

LogAnalysisApp.RequestCounterHandler() - Constructor for class co.cask.cdap.examples.loganalysis.LogAnalysisApp.RequestCounterHandler

LogAnalysisApp.ResponseCounterHandler - Class in co.cask.cdap.examples.loganalysis

A Service that responds with total number of responses for a given response code

LogAnalysisApp.ResponseCounterHandler() - Constructor for class co.cask.cdap.examples.loganalysis.LogAnalysisApp.ResponseCounterHandler

LogAnalysisApp.ResponseCounterSpark - Class in co.cask.cdap.examples.loganalysis

Specification for the Spark program in this application

LogAnalysisApp.ResponseCounterSpark() - Constructor for class co.cask.cdap.examples.loganalysis.LogAnalysisApp.ResponseCounterSpark

M

map(LongWritable, Text, Mapper<LongWritable, Text, Text, IntWritable>.Context) - Method in class co.cask.cdap.examples.loganalysis.HitCounterProgram.Emitter

P

parseFromLogLine(String) - Static method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

R

reduce(Text, Iterable<IntWritable>, Reducer<Text, IntWritable, byte[], byte[]>.Context) - Method in class co.cask.cdap.examples.loganalysis.HitCounterProgram.Counter

REQ_COUNT_STORE - Static variable in class co.cask.cdap.examples.loganalysis.LogAnalysisApp

REQUEST_COUNTER_SERVICE - Static variable in class co.cask.cdap.examples.loganalysis.LogAnalysisApp

RESPONSE_COUNT_STORE - Static variable in class co.cask.cdap.examples.loganalysis.LogAnalysisApp

RESPONSE_COUNTER_SERVICE - Static variable in class co.cask.cdap.examples.loganalysis.LogAnalysisApp

S

setClientIdentd(String) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

setContentSize(long) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

setDateTimeString(String) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

setEndpoint(String) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

setIpAddress(String) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

setMethod(String) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

setProtocol(String) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

setResponseCode(int) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

setUserID(String) - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

T

toString() - Method in class co.cask.cdap.examples.loganalysis.ApacheAccessLog

A C G H I L M P R S T