public class WorkerList extends ArrayList<URL>
modCount
Constructor and Description |
---|
WorkerList()
Creates an empty
WorkerList that can be populated manually
with worker URLs to support multi-head operations. |
WorkerList(GPUdb gpudb)
Creates a
WorkerList and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. |
WorkerList(GPUdb gpudb,
Pattern ipRegex)
Creates a
WorkerList and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. |
WorkerList(GPUdb gpudb,
String ipPrefix)
Creates a
WorkerList and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. |
Modifier and Type | Method and Description |
---|---|
Pattern |
getIpRegex() |
boolean |
isMultiHeadEnabled()
return a boolean indicating whether multi-head I/O is enabled at the
server.
|
add, add, addAll, addAll, clear, clone, contains, ensureCapacity, forEach, get, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, removeRange, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, trimToSize
equals, hashCode
containsAll, toString
finalize, getClass, notify, notifyAll, wait, wait, wait
containsAll, equals, hashCode
parallelStream, stream
public WorkerList()
WorkerList
that can be populated manually
with worker URLs to support multi-head operations. Note that worker URLs
must be added in rank order, starting with rank 1, and all worker
ranks must be included; otherwise operations may fail for certain
data types.public WorkerList(GPUdb gpudb) throws GPUdbException
WorkerList
and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. (If the
specified GPUdb instance has multi-head operations disabled, the worker
list will be empty and multi-head operations will not be used.) Note that
in some cases, workers may be configured to use more than one IP
address, not all of which may be accessible to the client; this
constructor uses the first IP returned by the server for each worker.
To override this behavior, use one of the alternate constructors that
accepts an IP regex
or an IP prefix
.gpudb
- the GPUdb
instance from which to obtain the
worker URLsGPUdbException
- if an error occurs during the request for
worker URLspublic WorkerList(GPUdb gpudb, Pattern ipRegex) throws GPUdbException
WorkerList
and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. (If the
specified GPUdb instance has multi-head operations disabled, the worker
list will be empty and multi-head operations will not be used.) Note that
in some cases, workers may be configured to use more than one IP
address, not all of which may be accessible to the client; the
optional ipRegex
parameter can be used in such cases to
filter for an IP range that is accessible, e.g., a regex of
"192\.168\..*"
will use worker IP addresses in the 192.168.*
range.gpudb
- the GPUdb
instance from which to obtain the
worker URLsipRegex
- optional IP regex to matchGPUdbException
- if an error occurs during the request for
worker URLs or no IP addresses matching the IP regex could be found
for one or more workerspublic WorkerList(GPUdb gpudb, String ipPrefix) throws GPUdbException
WorkerList
and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. (If the
specified GPUdb instance has multi-head operations disabled, the worker
list will be empty and multi-head operations will not be used.) Note that
in some cases, workers may be configured to use more than one IP
address, not all of which may be accessible to the client; the
optional ipprefix
parameter can be used in such cases to
filter for an IP range that is accessible, e.g., a prefix of
"192.168."
will use worker IP addresses in the 192.168.*
range.gpudb
- the GPUdb
instance from which to obtain the
worker URLsipPrefix
- optional IP prefix to matchGPUdbException
- if an error occurs during the request for
worker URLs or no IP addresses matching the IP prefix could be found
for one or more workerspublic Pattern getIpRegex()
public boolean isMultiHeadEnabled()
Copyright © 2020. All rights reserved.