public class HttpLoadQueuePeon extends LoadQueuePeon
Modifier and Type | Field and Description |
---|---|
static com.fasterxml.jackson.core.type.TypeReference |
REQUEST_ENTITY_TYPE_REF |
static com.fasterxml.jackson.core.type.TypeReference |
RESPONSE_ENTITY_TYPE_REF |
Constructor and Description |
---|
HttpLoadQueuePeon(String baseUrl,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
HttpClient httpClient,
DruidCoordinatorConfig config,
ScheduledExecutorService processingExecutor,
ExecutorService callBackExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
dropSegment(DataSegment segment,
LoadPeonCallback callback) |
int |
getAndResetFailedAssignCount() |
long |
getLoadQueueSize() |
int |
getNumberOfSegmentsInQueue() |
Set<DataSegment> |
getSegmentsMarkedToDrop() |
Set<DataSegment> |
getSegmentsToDrop() |
Set<DataSegment> |
getSegmentsToLoad() |
void |
loadSegment(DataSegment segment,
LoadPeonCallback callback) |
void |
markSegmentToDrop(DataSegment dataSegment) |
void |
start() |
void |
stop() |
void |
unmarkSegmentToDrop(DataSegment dataSegment) |
public static final com.fasterxml.jackson.core.type.TypeReference REQUEST_ENTITY_TYPE_REF
public static final com.fasterxml.jackson.core.type.TypeReference RESPONSE_ENTITY_TYPE_REF
public HttpLoadQueuePeon(String baseUrl, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, HttpClient httpClient, DruidCoordinatorConfig config, ScheduledExecutorService processingExecutor, ExecutorService callBackExecutor)
public void start()
start
in class LoadQueuePeon
public void stop()
stop
in class LoadQueuePeon
public void loadSegment(DataSegment segment, LoadPeonCallback callback)
loadSegment
in class LoadQueuePeon
public void dropSegment(DataSegment segment, LoadPeonCallback callback)
dropSegment
in class LoadQueuePeon
public Set<DataSegment> getSegmentsToLoad()
getSegmentsToLoad
in class LoadQueuePeon
public Set<DataSegment> getSegmentsToDrop()
getSegmentsToDrop
in class LoadQueuePeon
public long getLoadQueueSize()
getLoadQueueSize
in class LoadQueuePeon
public int getAndResetFailedAssignCount()
getAndResetFailedAssignCount
in class LoadQueuePeon
public void markSegmentToDrop(DataSegment dataSegment)
markSegmentToDrop
in class LoadQueuePeon
public void unmarkSegmentToDrop(DataSegment dataSegment)
unmarkSegmentToDrop
in class LoadQueuePeon
public int getNumberOfSegmentsInQueue()
getNumberOfSegmentsInQueue
in class LoadQueuePeon
public Set<DataSegment> getSegmentsMarkedToDrop()
getSegmentsMarkedToDrop
in class LoadQueuePeon
Copyright © 2011–2018. All rights reserved.