org.apache.drill.exec.store.schedule

Class EndpointByteMapImpl

java.lang.Object

org.apache.drill.exec.store.schedule.EndpointByteMapImpl

All Implemented Interfaces:

Iterable<com.carrotsearch.hppc.cursors.ObjectLongCursor<CoordinationProtos.DrillbitEndpoint>>, EndpointByteMap

public class EndpointByteMapImpl
extends Object
implements EndpointByteMap

Constructor Summary

Constructors

Constructor and Description
EndpointByteMapImpl()

Method Summary

Modifier and Type	Method and Description
void	add(CoordinationProtos.DrillbitEndpoint endpoint, long bytes)
long	get(CoordinationProtos.DrillbitEndpoint endpoint)
long	getMaxBytes()
boolean	isEmpty()
boolean	isSet(CoordinationProtos.DrillbitEndpoint endpoint)
Iterator<com.carrotsearch.hppc.cursors.ObjectLongCursor<CoordinationProtos.DrillbitEndpoint>>	iterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

EndpointByteMapImpl

public EndpointByteMapImpl()

Method Detail

isSet

public boolean isSet(CoordinationProtos.DrillbitEndpoint endpoint)

Specified by:

isSet in interface EndpointByteMap

get

public long get(CoordinationProtos.DrillbitEndpoint endpoint)

Specified by:

get in interface EndpointByteMap

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface EndpointByteMap

add

public void add(CoordinationProtos.DrillbitEndpoint endpoint,
                long bytes)

Specified by:

add in interface EndpointByteMap

getMaxBytes

public long getMaxBytes()

Specified by:

getMaxBytes in interface EndpointByteMap

iterator

public Iterator<com.carrotsearch.hppc.cursors.ObjectLongCursor<CoordinationProtos.DrillbitEndpoint>> iterator()

Specified by:

iterator in interface Iterable<com.carrotsearch.hppc.cursors.ObjectLongCursor<CoordinationProtos.DrillbitEndpoint>>