Summary
Nested Classes |
class |
BucketedExecutorSettings.Builder<T extends Serializable> |
Builder for BucketedExecutorSettings |
[Expand]
Inherited Methods |
From class
java.lang.Object
Object
|
clone()
|
boolean
|
equals(Object arg0)
|
void
|
finalize()
|
final
Class<?>
|
getClass()
|
int
|
hashCode()
|
final
void
|
notify()
|
final
void
|
notifyAll()
|
String
|
toString()
|
final
void
|
wait(long arg0, int arg1)
|
final
void
|
wait(long arg0)
|
final
void
|
wait()
|
|
Public Methods
public
int
getBatchSize
()
Returns
- the number of items from a bucket that should be processed in a single
BucketProcessor
run. The
number of items that are passed to a BucketProcessor
is guaranteed to be <= the configured
batch size.
@Nonnull
public
Function<T, String>
getBucketIdExtractor
()
Returns
- the function used to group items in buckets
public
int
getMaxAttempts
()
Returns
- the maximum number of times processing of a bucket should be attempted
public
int
getMaxConcurrency
()
Returns
- the maximum number of different buckets that can be concurrently processed
@Nonnull
public
ConcurrencyPolicy
getMaxConcurrencyPolicy
()
Returns
- the concurrency policy. If the concurrency policy is
PER_CLUSTER
, the maximum concurrency
is translated into a per-node maximum by dividing the maximum
by the number of nodes in the cluster (rounded up).
@Nonnull
public
BucketProcessor<T>
getProcessor
()
Returns
- the processor responsible for processing buckets of tasks