public class IndexingServiceClient extends Object
Constructor and Description |
---|
IndexingServiceClient(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
DruidLeaderClient druidLeaderClient) |
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) |
@Inject public IndexingServiceClient(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DruidLeaderClient druidLeaderClient)
public void mergeSegments(List<DataSegment> segments)
public void killSegments(String dataSource, org.joda.time.Interval interval)
public void upgradeSegment(DataSegment dataSegment)
public void upgradeSegments(String dataSource, org.joda.time.Interval interval)
public List<TaskStatusPlus> getRunningTasks()
public List<TaskStatusPlus> getPendingTasks()
public List<TaskStatusPlus> getWaitingTasks()
@Nullable public TaskStatusPlus getLastCompleteTask()
public int killPendingSegments(String dataSource, org.joda.time.DateTime end)
Copyright © 2011–2018. All rights reserved.