public class LoadQueuePeon extends Object
Modifier and Type | Method and Description |
---|---|
void |
dropSegment(DataSegment segment,
LoadPeonCallback callback) |
int |
getAndResetFailedAssignCount() |
long |
getLoadQueueSize() |
Set<DataSegment> |
getSegmentsToDrop() |
Set<DataSegment> |
getSegmentsToLoad() |
void |
loadSegment(DataSegment segment,
LoadPeonCallback callback) |
void |
start() |
void |
stop() |
public Set<DataSegment> getSegmentsToLoad()
public Set<DataSegment> getSegmentsToDrop()
public long getLoadQueueSize()
public int getAndResetFailedAssignCount()
public void loadSegment(DataSegment segment, LoadPeonCallback callback)
public void dropSegment(DataSegment segment, LoadPeonCallback callback)
public void start()
public void stop()
Copyright © 2011–2017. All rights reserved.