co.cask.cdap.examples.wordcount

Class WordSplitter

java.lang.Object

co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable<FlowletConfigurer>

co.cask.cdap.api.flow.flowlet.AbstractFlowlet

co.cask.cdap.examples.wordcount.WordSplitter

All Implemented Interfaces:

Callback, Flowlet, ProgramLifecycle<FlowletContext>

public class WordSplitter
extends AbstractFlowlet

Word splitter Flowlet.

Constructor Summary

Constructors

Constructor and Description
WordSplitter(String wordStatsTableName)

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize(FlowletContext context)
void	process(StreamEvent event)

Methods inherited from class co.cask.cdap.api.flow.flowlet.AbstractFlowlet

configure, configure, destroy, getConfigurer, getContext, onFailure, onSuccess, setDescription, setFailurePolicy, setName, setProperties, setResources, useDatasets, useDatasets

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

WordSplitter

public WordSplitter(String wordStatsTableName)

Method Detail

initialize

public void initialize(FlowletContext context)
                throws Exception

Specified by:

initialize in interface Flowlet

Specified by:

initialize in interface ProgramLifecycle<FlowletContext>

Overrides:

initialize in class AbstractFlowlet

Throws:

Exception

process

public void process(StreamEvent event)