| 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)  | 
AbstractTask(String id,
            String groupId,
            TaskResource taskResource,
            String dataSource,
            Map<String,Object> context)  | 
CompactionTask(String id,
              TaskResource taskResource,
              String dataSource,
              org.joda.time.Interval interval,
              List<DataSegment> segments,
              DimensionsSpec dimensionsSpec,
              IndexTask.IndexTuningConfig tuningConfig,
              Map<String,Object> context,
              com.fasterxml.jackson.databind.ObjectMapper jsonMapper)  | 
IndexTask(String id,
         TaskResource taskResource,
         IndexTask.IndexIngestionSpec ingestionSchema,
         Map<String,Object> context)  | 
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,
              AuthorizerMapper authorizerMapper)  | 
| 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–2018. All rights reserved.