co.cask.cdap.examples.loganalysis

Class LogAnalysisApp.RequestCounterHandler

java.lang.Object

co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable

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

co.cask.cdap.api.service.http.AbstractHttpServiceHandler

co.cask.cdap.examples.loganalysis.LogAnalysisApp.RequestCounterHandler

All Implemented Interfaces:

HttpServiceHandler

Enclosing class:

LogAnalysisApp

public static final class LogAnalysisApp.RequestCounterHandler
extends AbstractHttpServiceHandler

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

Constructor Summary

Constructors

Constructor and Description
LogAnalysisApp.RequestCounterHandler()

Method Summary

Methods

Modifier and Type	Method and Description
void	getRequestFilesetContents(HttpServiceRequest request, HttpServiceResponder responder) Handler which reads all the parts files from a given partition in LogAnalysisApp.REQ_COUNT_STORE TimePartitionedFileSet and send it as a string.
void	getRequestFilesetPartitions(HttpServiceRequest request, HttpServiceResponder responder) Handler which lists all the different time partitions available in the LogAnalysisApp.REQ_COUNT_STORE TimePartitionedFileSet

Methods inherited from class co.cask.cdap.api.service.http.AbstractHttpServiceHandler

configure, configure, destroy, getConfigurer, getContext, initialize, setProperties, useDatasets, useDatasets

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

LogAnalysisApp.RequestCounterHandler

public LogAnalysisApp.RequestCounterHandler()

Method Detail

getRequestFilesetPartitions

public void getRequestFilesetPartitions(HttpServiceRequest request,
                               HttpServiceResponder responder)

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

getRequestFilesetContents

public void getRequestFilesetContents(HttpServiceRequest request,
                             HttpServiceResponder responder)

Handler which reads all the parts files from a given partition in LogAnalysisApp.REQ_COUNT_STORE TimePartitionedFileSet and send it as a string. Note: We make an assumption here that the contents for partitions in the tpfs for this example is not very huge. This method of serving contents is not ideal for large contents.