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.