protected class TwitterUserstreamElasticsearch.SetDeleteIdProcessor extends Object implements org.apache.streams.core.StreamsProcessor
Modifier | Constructor and Description |
---|---|
protected |
SetDeleteIdProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
String |
getId() |
void |
prepare(Object configurationObject) |
List<org.apache.streams.core.StreamsDatum> |
process(org.apache.streams.core.StreamsDatum entry) |
public String getId()
getId
in interface org.apache.streams.core.StreamsOperation
public List<org.apache.streams.core.StreamsDatum> process(org.apache.streams.core.StreamsDatum entry)
process
in interface org.apache.streams.core.StreamsProcessor
public void prepare(Object configurationObject)
prepare
in interface org.apache.streams.core.StreamsOperation
public void cleanUp()
cleanUp
in interface org.apache.streams.core.StreamsOperation
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.