co.cask.cdap.examples.webanalytics

Class UniqueVisitor

java.lang.Object

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

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

co.cask.cdap.examples.webanalytics.UniqueVisitor

All Implemented Interfaces:

Callback, Flowlet, ProgramLifecycle<FlowletContext>

public class UniqueVisitor
extends AbstractFlowlet

UniqueVisitor, a data processing node that processes collected data. In this scenario the input is directly from the stream DataStream itself, the this process function then splits the line using spaces and records the first element into the Dataset UniqueVisitCount. If the element has been recorded before, the Dataset will increment the value of the element.

Constructor Summary

Constructors

Constructor and Description
UniqueVisitor()

Method Summary

Methods

Modifier and Type	Method and Description
void	process(StreamEvent streamEvent)

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

configure, configure, destroy, getConfigurer, getContext, initialize, 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

UniqueVisitor

public UniqueVisitor()

Method Detail

process

public void process(StreamEvent streamEvent)