co.cask.cdap.examples.sparkkmeans

Class SparkKMeansApp.PointsFlow

java.lang.Object

co.cask.cdap.examples.sparkkmeans.SparkKMeansApp.PointsFlow

All Implemented Interfaces:

Flow, Processor

Enclosing class:

SparkKMeansApp

public static final class SparkKMeansApp.PointsFlow
extends Object
implements Flow

This is a simple Flow that consumes points from a Stream and stores them in a dataset.

Constructor Summary

Constructors

Constructor and Description
SparkKMeansApp.PointsFlow()

Method Summary

Methods

Modifier and Type	Method and Description
FlowSpecification	configure()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkKMeansApp.PointsFlow

public SparkKMeansApp.PointsFlow()

Method Detail

configure

public FlowSpecification configure()

Specified by:

configure in interface Flow