public class PercolateTagProcessor extends Object implements StreamsProcessor
Modifier and Type | Class and Description |
---|---|
static class |
PercolateTagProcessor.FilterLevel |
static class |
PercolateTagProcessor.PercolateQueryBuilder |
Modifier and Type | Field and Description |
---|---|
protected Queue<StreamsDatum> |
inQueue |
protected Queue<StreamsDatum> |
outQueue |
static String |
STREAMS_ID |
static String |
TAGS_EXTENSION |
protected String |
usePercolateField |
Constructor and Description |
---|
PercolateTagProcessor(ElasticsearchWriterConfiguration config) |
PercolateTagProcessor(ElasticsearchWriterConfiguration config,
String defaultPercolateField) |
Modifier and Type | Method and Description |
---|---|
void |
addPercolateRule(PercolateTagProcessor.PercolateQueryBuilder builder,
String index) |
protected void |
appendMatches(com.fasterxml.jackson.databind.node.ArrayNode tagArray,
Activity activity) |
void |
cleanUp() |
void |
createIndexIfMissing(String indexName)
createIndexIfMissing.
|
boolean |
deleteOldQueries(String index)
delete old queries.
|
Set<String> |
getActivePercolateTags(String index)
get active percolate tags.
|
ElasticsearchConfiguration |
getConfig() |
String |
getId() |
ElasticsearchClientManager |
getManager() |
Queue<StreamsDatum> |
getProcessorOutputQueue() |
int |
numOfPercolateRules() |
void |
prepare(Object configuration) |
List<StreamsDatum> |
process(StreamsDatum entry) |
boolean |
removeOldTags(Set<String> ids,
String index)
Attempt to removeOldTags.
|
void |
setConfig(ElasticsearchWriterConfiguration config) |
void |
setManager(ElasticsearchClientManager manager) |
boolean |
writePercolateRules() |
public static final String STREAMS_ID
protected Queue<StreamsDatum> inQueue
protected Queue<StreamsDatum> outQueue
public static final String TAGS_EXTENSION
protected String usePercolateField
public PercolateTagProcessor(ElasticsearchWriterConfiguration config)
public PercolateTagProcessor(ElasticsearchWriterConfiguration config, String defaultPercolateField)
public ElasticsearchClientManager getManager()
public void setManager(ElasticsearchClientManager manager)
public ElasticsearchConfiguration getConfig()
public void setConfig(ElasticsearchWriterConfiguration config)
public Queue<StreamsDatum> getProcessorOutputQueue()
public String getId()
getId
in interface StreamsOperation
public List<StreamsDatum> process(StreamsDatum entry)
process
in interface StreamsProcessor
protected void appendMatches(com.fasterxml.jackson.databind.node.ArrayNode tagArray, Activity activity)
public void prepare(Object configuration)
prepare
in interface StreamsOperation
public void cleanUp()
cleanUp
in interface StreamsOperation
public int numOfPercolateRules()
public void createIndexIfMissing(String indexName)
indexName
- indexNamepublic void addPercolateRule(PercolateTagProcessor.PercolateQueryBuilder builder, String index)
public boolean writePercolateRules()
public boolean removeOldTags(Set<String> ids, String index)
ids
- idsindex
- indexpublic Set<String> getActivePercolateTags(String index)
index
- indexpublic boolean deleteOldQueries(String index)
index
- indexCopyright © 2018 The Apache Software Foundation. All rights reserved.