public class VerbDefinitionKeepFilter extends Object implements StreamsProcessor
Modifier and Type | Field and Description |
---|---|
protected VerbDefinitionResolver |
resolver |
static String |
STREAMS_ID |
protected Set<VerbDefinition> |
verbDefinitionSet |
Constructor and Description |
---|
VerbDefinitionKeepFilter() |
VerbDefinitionKeepFilter(Set<VerbDefinition> verbDefinitionSet) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
String |
getId() |
void |
prepare(Object o) |
List<StreamsDatum> |
process(StreamsDatum entry) |
public static final String STREAMS_ID
protected Set<VerbDefinition> verbDefinitionSet
protected VerbDefinitionResolver resolver
public VerbDefinitionKeepFilter()
public VerbDefinitionKeepFilter(Set<VerbDefinition> verbDefinitionSet)
public String getId()
getId
in interface StreamsOperation
public List<StreamsDatum> process(StreamsDatum entry)
process
in interface StreamsProcessor
public void prepare(Object o)
prepare
in interface StreamsOperation
public void cleanUp()
cleanUp
in interface StreamsOperation
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.