Package | Description |
---|---|
io.druid.indexing.common.task | |
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) |
AbstractTask(String id,
String groupId,
TaskResource taskResource,
String dataSource) |
RealtimeIndexTask(String id,
TaskResource taskResource,
FireDepartment fireDepartment,
Schema spec,
io.druid.data.input.FirehoseFactory firehoseFactory,
FireDepartmentConfig fireDepartmentConfig,
org.joda.time.Period windowPeriod,
int maxPendingPersists,
com.metamx.common.Granularity segmentGranularity,
RejectionPolicyFactory rejectionPolicy,
RejectionPolicyFactory rejectionPolicyFactory) |
Modifier and Type | Method and Description |
---|---|
TaskResource |
TaskAnnouncement.getTaskResource() |
Copyright © 2015. All rights reserved.