co.cask.cdap.examples.wordcount

Class WordAssociator

java.lang.Object

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

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

co.cask.cdap.examples.wordcount.WordAssociator

All Implemented Interfaces:

Callback, Flowlet, ProgramLifecycle<FlowletContext>

public class WordAssociator
extends AbstractFlowlet

Word associator Flowlet.

Constructor Summary

Constructors

Constructor and Description
WordAssociator(String wordAssocTableName)

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize(FlowletContext context)
void	process(Set<String> words)

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

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

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

WordAssociator

public WordAssociator(String wordAssocTableName)

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(Set<String> words)