co.cask.cdap.examples.sparkstreaming

Class SpamClassifier

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

All Implemented Interfaces:

Application

public class SpamClassifier
extends AbstractApplication

Spark Streaming Example for classifying kafka messages through Spark MlLib NaiveBayesModel

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SpamClassifier.SpamClassifierServiceHandler A Service handler to get the classification of kafka messages

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATASET
static String	STREAM

Constructor Summary

Constructors

Constructor and Description
SpamClassifier()

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, buildSchedule, configure, getConfig, getConfigurer, getContext, getTriggerFactory, schedule, 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

STREAM

public static final String STREAM

See Also:

Constant Field Values

DATASET

public static final String DATASET

See Also:

Constant Field Values

Constructor Detail

SpamClassifier

public SpamClassifier()

Method Detail

configure

public void configure()

Specified by:

configure in class AbstractApplication