org.apache.streams.example

Class TwitterUserstreamElasticsearch.SetDeleteIdProcessor

java.lang.Object

org.apache.streams.example.TwitterUserstreamElasticsearch.SetDeleteIdProcessor

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProcessor

Enclosing class:

TwitterUserstreamElasticsearch

protected class TwitterUserstreamElasticsearch.SetDeleteIdProcessor
extends Object
implements StreamsProcessor

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SetDeleteIdProcessor()

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
String	getId()
void	prepare(Object configurationObject)
List<StreamsDatum>	process(StreamsDatum entry)

Methods inherited from class java.lang.Object

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

Constructor Detail

SetDeleteIdProcessor

protected SetDeleteIdProcessor()

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

process

public List<StreamsDatum> process(StreamsDatum entry)

Specified by:

process in interface StreamsProcessor

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation