public class IndexTask extends AbstractFixedIntervalTask
Modifier and Type | Class and Description |
---|---|
static class |
IndexTask.IndexIngestionSpec |
static class |
IndexTask.IndexIOConfig |
static class |
IndexTask.IndexTuningConfig |
Constructor and Description |
---|
IndexTask(String id,
TaskResource taskResource,
IndexTask.IndexIngestionSpec ingestionSchema,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
IndexTask.IndexIngestionSpec |
getIngestionSchema() |
String |
getType()
Returns a descriptive label for this task type.
|
TaskStatus |
run(TaskToolbox toolbox)
Execute a task.
|
getInterval, isReady
canRestore, equals, getClasspathPrefix, getContext, getContextValue, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskLocks, getTaskResource, hashCode, joinId, makeId, stopGracefully, success, toString
public IndexTask(String id, TaskResource taskResource, IndexTask.IndexIngestionSpec ingestionSchema, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, Map<String,Object> context)
public String getType()
Task
public IndexTask.IndexIngestionSpec getIngestionSchema()
public TaskStatus run(TaskToolbox toolbox) throws Exception
Task
toolbox
- Toolbox for this taskException
- if this task failedCopyright © 2011–2016. All rights reserved.