io.druid.indexing.overlord

Class RemoteTaskRunnerWorkQueue

java.lang.Object

java.util.AbstractMap<K,V>

java.util.concurrent.ConcurrentSkipListMap<String,RemoteTaskRunnerWorkItem>

io.druid.indexing.overlord.RemoteTaskRunnerWorkQueue

All Implemented Interfaces:

Serializable, Cloneable, ConcurrentMap<String,RemoteTaskRunnerWorkItem>, ConcurrentNavigableMap<String,RemoteTaskRunnerWorkItem>, Map<String,RemoteTaskRunnerWorkItem>, NavigableMap<String,RemoteTaskRunnerWorkItem>, SortedMap<String,RemoteTaskRunnerWorkItem>

public class RemoteTaskRunnerWorkQueue
extends ConcurrentSkipListMap<String,RemoteTaskRunnerWorkItem>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Constructor Summary

Constructors

Constructor and Description
RemoteTaskRunnerWorkQueue()

Method Summary

Methods

Modifier and Type	Method and Description
RemoteTaskRunnerWorkItem	put(String s, RemoteTaskRunnerWorkItem taskRunnerWorkItem)

Methods inherited from class java.util.concurrent.ConcurrentSkipListMap

ceilingEntry, ceilingKey, clear, clone, comparator, containsKey, containsValue, descendingKeySet, descendingMap, entrySet, equals, firstEntry, firstKey, floorEntry, floorKey, get, headMap, headMap, higherEntry, higherKey, isEmpty, keySet, lastEntry, lastKey, lowerEntry, lowerKey, navigableKeySet, pollFirstEntry, pollLastEntry, putIfAbsent, remove, remove, replace, replace, size, subMap, subMap, tailMap, tailMap, values

Methods inherited from class java.util.AbstractMap

hashCode, putAll, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

hashCode, putAll

Constructor Detail

RemoteTaskRunnerWorkQueue

public RemoteTaskRunnerWorkQueue()

Method Detail

put

public RemoteTaskRunnerWorkItem put(String s,
                           RemoteTaskRunnerWorkItem taskRunnerWorkItem)

Specified by:

put in interface Map<String,RemoteTaskRunnerWorkItem>

Overrides:

put in class ConcurrentSkipListMap<String,RemoteTaskRunnerWorkItem>