co.cask.cdap.examples.wordcount

Class Counter

java.lang.Object

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

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

co.cask.cdap.examples.wordcount.Counter

All Implemented Interfaces:

Callback, Flowlet, ProgramLifecycle<FlowletContext>

public class Counter
extends AbstractFlowlet

Counter Flowlet.

Constructor Summary

Constructors

Constructor and Description
Counter(String wordCountTableName)

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize(FlowletContext context)
void	process(String word)

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

Counter

public Counter(String wordCountTableName)

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(String word)