io.druid.client.indexing

Class IndexingServiceClient

java.lang.Object

io.druid.client.indexing.IndexingServiceClient

public class IndexingServiceClient
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
TaskStatusPlus	getLastCompleteTask()
List<TaskStatusPlus>	getPendingTasks()
List<TaskStatusPlus>	getRunningTasks()
List<TaskStatusPlus>	getWaitingTasks()
int	killPendingSegments(String dataSource, org.joda.time.DateTime end)
void	killSegments(String dataSource, org.joda.time.Interval interval)
void	mergeSegments(List<DataSegment> segments)
void	upgradeSegment(DataSegment dataSegment)
void	upgradeSegments(String dataSource, org.joda.time.Interval interval)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexingServiceClient

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

Method Detail

mergeSegments

public void mergeSegments(List<DataSegment> segments)

killSegments

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

upgradeSegment

public void upgradeSegment(DataSegment dataSegment)

upgradeSegments

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

getRunningTasks

public List<TaskStatusPlus> getRunningTasks()

getPendingTasks

public List<TaskStatusPlus> getPendingTasks()

getWaitingTasks

public List<TaskStatusPlus> getWaitingTasks()

getLastCompleteTask

@Nullable
public TaskStatusPlus getLastCompleteTask()

killPendingSegments

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