co.cask.cdap.examples.sparkkmeans

Class SparkKMeansApp

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.sparkkmeans.SparkKMeansApp

All Implemented Interfaces:

Application

public class SparkKMeansApp
extends AbstractApplication

Application that demonstrate KMeans Clustering example.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SparkKMeansApp.CentersService A Service that responds with calculated center based on index parameter.
static class	SparkKMeansApp.CentersServiceHandler Centers Service handler.
static class	SparkKMeansApp.PointsFlow This is a simple Flow that consumes points from a Stream and stores them in a dataset.
static class	SparkKMeansApp.PointsReader This Flowlet reads events from a Stream and saves them to a dataset.
static class	SparkKMeansApp.SparkKMeansSpecification A Spark Program that uses KMeans algorithm.

Constructor Summary

Constructors

Constructor and Description
SparkKMeansApp()

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, 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

Constructor Detail

SparkKMeansApp

public SparkKMeansApp()

Method Detail

configure

public void configure()

Specified by:

configure in class AbstractApplication