co.cask.cdap.examples.sparkstreaming

Class SpamClassifier.SpamClassifierServiceHandler

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.sparkstreaming.SpamClassifier.SpamClassifierServiceHandler

All Implemented Interfaces:

ProgramLifecycle<HttpServiceContext>, HttpServiceHandler

Enclosing class:

SpamClassifier

public static final class SpamClassifier.SpamClassifierServiceHandler
extends AbstractHttpServiceHandler

A Service handler to get the classification of kafka messages

Constructor Summary

Constructors

Constructor and Description
SpamClassifierServiceHandler()

Method Summary

Modifier and Type	Method and Description
void	centers(HttpServiceRequest request, HttpServiceResponder responder, String messageId)

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

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

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

SpamClassifierServiceHandler

public SpamClassifierServiceHandler()

Method Detail

centers

@Path(value="classification/{message-id}")
 @GET
public void centers(HttpServiceRequest request,
                                                                     HttpServiceResponder responder,
                                                                     @PathParam(value="message-id")
                                                                     String messageId)