org.apache.spark.resource

Interface ResourceAllocator

public interface ResourceAllocator

Trait used to help executor/worker allocate resources. Please note that this is intended to be used in a single thread.

Method Summary

Modifier and Type	Method and Description
void	acquire(scala.collection.Seq<String> addrs) Acquire a sequence of resource addresses (to a launched task), these addresses must be available.
scala.collection.Seq<String>	assignedAddrs() Sequence of currently assigned resource addresses.
scala.collection.Seq<String>	availableAddrs() Sequence of currently available resource addresses.
void	release(scala.collection.Seq<String> addrs) Release a sequence of resource addresses, these addresses must have been assigned.
scala.collection.Seq<String>	resourceAddresses()
String	resourceName()

Method Detail

acquire

void acquire(scala.collection.Seq<String> addrs)

Acquire a sequence of resource addresses (to a launched task), these addresses must be available. When the task finishes, it will return the acquired resource addresses. Throw an Exception if an address is not available or doesn't exist.

Parameters:

addrs - (undocumented)

assignedAddrs

scala.collection.Seq<String> assignedAddrs()

Sequence of currently assigned resource addresses.

Returns:

(undocumented)

availableAddrs

scala.collection.Seq<String> availableAddrs()

Sequence of currently available resource addresses.

Returns:

(undocumented)

release

void release(scala.collection.Seq<String> addrs)

Release a sequence of resource addresses, these addresses must have been assigned. Resource addresses are released when a task has finished. Throw an Exception if an address is not assigned or doesn't exist.

Parameters:

addrs - (undocumented)

resourceAddresses

scala.collection.Seq<String> resourceAddresses()

resourceName

String resourceName()