@Internal public abstract class AbstractESDeleteByQueryTask extends Object implements ESTask
Modifier and Type | Field and Description |
---|---|
protected static org.elasticsearch.common.unit.TimeValue |
SCROLL_KEEP_ALIVE |
protected static int |
SCROLL_SIZE |
Constructor and Description |
---|
AbstractESDeleteByQueryTask() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
delete(ESIndexRequestProcessor processor,
org.elasticsearch.search.SearchHit hit,
long order) |
protected abstract org.elasticsearch.client.Client |
getClient() |
long |
getOrder() |
protected abstract org.elasticsearch.index.query.QueryBuilder |
getQuery() |
protected abstract String[] |
getTypes() |
void |
perform(ESIndexRequestProcessor processor)
Perform this task with the specified ES Task processor.
|
void |
setOrder(long order)
Set order of the task used for optimistic concurrency control
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDescription
convertToJournalEntry
protected static final org.elasticsearch.common.unit.TimeValue SCROLL_KEEP_ALIVE
protected static final int SCROLL_SIZE
public void perform(ESIndexRequestProcessor processor)
ESTask
public void setOrder(long order)
ESTask
public long getOrder()
protected abstract org.elasticsearch.client.Client getClient()
protected abstract org.elasticsearch.index.query.QueryBuilder getQuery()
protected abstract String[] getTypes()
protected abstract void delete(ESIndexRequestProcessor processor, org.elasticsearch.search.SearchHit hit, long order)
Copyright © 2003–2015 Atlassian. All rights reserved.