| Package | Description |
|---|---|
| io.druid.indexing.common.task | |
| io.druid.indexing.kafka | |
| io.druid.indexing.worker |
| Modifier and Type | Method and Description |
|---|---|
TaskResource |
Task.getTaskResource()
Returns a
TaskResource for this task. |
TaskResource |
AbstractTask.getTaskResource() |
| Constructor and Description |
|---|
AbstractFixedIntervalTask(String id,
String groupId,
TaskResource taskResource,
String dataSource,
org.joda.time.Interval interval,
Map<String,Object> context) |
AbstractFixedIntervalTask(String id,
TaskResource taskResource,
String dataSource,
org.joda.time.Interval interval,
Map<String,Object> context) |
AbstractTask(String id,
String groupId,
TaskResource taskResource,
String dataSource,
Map<String,Object> context) |
IndexTask(String id,
TaskResource taskResource,
IndexTask.IndexIngestionSpec ingestionSchema,
Map<String,Object> context,
com.fasterxml.jackson.databind.ObjectMapper smileMapper) |
RealtimeIndexTask(String id,
TaskResource taskResource,
FireDepartment fireDepartment,
Map<String,Object> context) |
| Constructor and Description |
|---|
KafkaIndexTask(String id,
TaskResource taskResource,
DataSchema dataSchema,
KafkaTuningConfig tuningConfig,
KafkaIOConfig ioConfig,
Map<String,Object> context,
ChatHandlerProvider chatHandlerProvider) |
| Modifier and Type | Method and Description |
|---|---|
TaskResource |
TaskAnnouncement.getTaskResource() |
| Modifier and Type | Method and Description |
|---|---|
static TaskAnnouncement |
TaskAnnouncement.create(String taskId,
TaskResource resource,
TaskStatus status,
TaskLocation location) |
Copyright © 2011–2017. All rights reserved.