org.apache.druid.client.indexing

Interface IndexingServiceClient

All Known Implementing Classes:

HttpIndexingServiceClient

public interface IndexingServiceClient

Method Summary

Modifier and Type	Method and Description
String	compactSegments(List<org.apache.druid.timeline.DataSegment> segments, boolean keepSegmentGranularity, long targetCompactionSizeBytes, int compactionTaskPriority, ClientCompactQueryTuningConfig tuningConfig, Map<String,Object> context)
org.apache.druid.indexer.TaskStatusPlus	getLastCompleteTask()
List<org.apache.druid.indexer.TaskStatusPlus>	getPendingTasks()
List<org.apache.druid.indexer.TaskStatusPlus>	getRunningTasks()
TaskStatusResponse	getTaskStatus(String taskId)
int	getTotalWorkerCapacity()
List<org.apache.druid.indexer.TaskStatusPlus>	getWaitingTasks()
int	killPendingSegments(String dataSource, org.joda.time.DateTime end)
void	killSegments(String dataSource, org.joda.time.Interval interval)
String	killTask(String taskId)
void	mergeSegments(List<org.apache.druid.timeline.DataSegment> segments)
String	runTask(Object taskObject)

Method Detail

killSegments

void killSegments(String dataSource,
                  org.joda.time.Interval interval)

killPendingSegments

int killPendingSegments(String dataSource,
                        org.joda.time.DateTime end)

mergeSegments

void mergeSegments(List<org.apache.druid.timeline.DataSegment> segments)

compactSegments

String compactSegments(List<org.apache.druid.timeline.DataSegment> segments,
                       boolean keepSegmentGranularity,
                       long targetCompactionSizeBytes,
                       int compactionTaskPriority,
                       @Nullable
                       ClientCompactQueryTuningConfig tuningConfig,
                       @Nullable
                       Map<String,Object> context)

getTotalWorkerCapacity

int getTotalWorkerCapacity()

runTask

String runTask(Object taskObject)

killTask

String killTask(String taskId)

getRunningTasks

List<org.apache.druid.indexer.TaskStatusPlus> getRunningTasks()

getPendingTasks

List<org.apache.druid.indexer.TaskStatusPlus> getPendingTasks()

getWaitingTasks

List<org.apache.druid.indexer.TaskStatusPlus> getWaitingTasks()

getTaskStatus

TaskStatusResponse getTaskStatus(String taskId)

getLastCompleteTask

@Nullable
org.apache.druid.indexer.TaskStatusPlus getLastCompleteTask()