io.druid.server.coordinator

Class LoadQueuePeon

java.lang.Object

io.druid.server.coordinator.LoadQueuePeon

public class LoadQueuePeon
extends Object

Method Summary

Methods

Modifier and Type	Method and Description
void	dropSegment(io.druid.timeline.DataSegment segment, LoadPeonCallback callback)
int	getAndResetFailedAssignCount()
long	getLoadQueueSize()
Set<io.druid.timeline.DataSegment>	getSegmentsToDrop()
Set<io.druid.timeline.DataSegment>	getSegmentsToLoad()
void	loadSegment(io.druid.timeline.DataSegment segment, LoadPeonCallback callback)
void	stop()

Methods inherited from class java.lang.Object

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

Method Detail

getSegmentsToLoad

public Set<io.druid.timeline.DataSegment> getSegmentsToLoad()

getSegmentsToDrop

public Set<io.druid.timeline.DataSegment> getSegmentsToDrop()

getLoadQueueSize

public long getLoadQueueSize()

getAndResetFailedAssignCount

public int getAndResetFailedAssignCount()

loadSegment

public void loadSegment(io.druid.timeline.DataSegment segment,
               LoadPeonCallback callback)

dropSegment

public void dropSegment(io.druid.timeline.DataSegment segment,
               LoadPeonCallback callback)

stop

public void stop()