org.apache.druid.client.indexing

Class HttpIndexingServiceClient

java.lang.Object

org.apache.druid.client.indexing.HttpIndexingServiceClient

All Implemented Interfaces:

IndexingServiceClient

public class HttpIndexingServiceClient
extends Object
implements IndexingServiceClient

Constructor Summary

Constructors

Constructor and Description
HttpIndexingServiceClient(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DruidLeaderClient druidLeaderClient)

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpIndexingServiceClient

@Inject
public HttpIndexingServiceClient(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                         DruidLeaderClient druidLeaderClient)

Method Detail

mergeSegments

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

Specified by:

mergeSegments in interface IndexingServiceClient

killSegments

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

Specified by:

killSegments in interface IndexingServiceClient

compactSegments

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

Specified by:

compactSegments in interface IndexingServiceClient

runTask

public String runTask(Object taskObject)

Specified by:

runTask in interface IndexingServiceClient

killTask

public String killTask(String taskId)

Specified by:

killTask in interface IndexingServiceClient

getTotalWorkerCapacity

public int getTotalWorkerCapacity()

Specified by:

getTotalWorkerCapacity in interface IndexingServiceClient

getRunningTasks

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

Specified by:

getRunningTasks in interface IndexingServiceClient

getPendingTasks

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

Specified by:

getPendingTasks in interface IndexingServiceClient

getWaitingTasks

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

Specified by:

getWaitingTasks in interface IndexingServiceClient

getTaskStatus

public TaskStatusResponse getTaskStatus(String taskId)

Specified by:

getTaskStatus in interface IndexingServiceClient

getLastCompleteTask

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

Specified by:

getLastCompleteTask in interface IndexingServiceClient

killPendingSegments

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

Specified by:

killPendingSegments in interface IndexingServiceClient