BulkOperationUtil (utils 3.0 API)

java.lang.Object
- com.bluejeans.common.utils.BulkOperationUtil<E>

Type Parameters:

E - the entity type
```
public class BulkOperationUtil<E>
extends Object
```
Bulk operation utils for queuing elements and performing bulk operation on them at once, interval based

Author:

Dinesh Ilindra

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static interface BulkOperationUtil.BulkOperation<E>
The interface for the bulk operation

Nested Classes
Modifier and Type	Class and Description
`static interface`	`BulkOperationUtil.BulkOperation<E>` The interface for the bulk operation

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`add(E e)` Add the given element to queue
`static <E> BulkOperationUtil<E>`	`create(int bulkPollInterval, int capacity, BulkOperationUtil.BulkOperation<E> bulkOperation)` Create based on parameters
`static <E> BulkOperationUtil<E>`	`create(int bulkPollInterval, int capacity, BulkOperationUtil.BulkOperation<E> bulkOperation, int batchSize, int bulkExecutorSize, int bulkExecutorQueueCapacity)` Create based on parameters
`void`	`doBulk()` Do the bulk operation.
`int`	`getBatchSize()`
`ThreadPoolExecutor`	`getBulkExecutor()`
`int`	`getBulkExecutorQueueCapacity()`
`int`	`getBulkExecutorSize()`
`BulkOperationUtil.BulkOperation<E>`	`getBulkOperation()`
`long`	`getBulkPollInterval()`
`Runnable`	`getBulkRunnable()`
`com.bluejeans.common.utils.BulkOperationUtil.Doer`	`getDoer()`
`int`	`getMinBatchSize()`
`AtomicLong`	`getOfferFailCount()`
`BlockingQueue<E>`	`getQueue()`
`int`	`getQueueSize()` Get the queue size
`boolean`	`isParallel()`
`boolean`	`isStopped()`
`void`	`setBatchSize(int batchSize)`
`void`	`setMinBatchSize(int minBatchSize)`
`void`	`setParallel(boolean parallel)`
`void`	`stop()` Stop the utility and operate on any remaining elements in queue.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static <E> BulkOperationUtil<E> create(int bulkPollInterval,
                                              int capacity,
                                              BulkOperationUtil.BulkOperation<E> bulkOperation,
                                              int batchSize,
                                              int bulkExecutorSize,
                                              int bulkExecutorQueueCapacity)

Create based on parameters

Type Parameters:: E - the entity type
Parameters:: bulkPollInterval - the poll interval; capacity - the queue capacity; bulkOperation - the bulk operation itself; batchSize - the drain batch size; bulkExecutorSize - the bulk executor size
Returns:: the created utility

create

public static <E> BulkOperationUtil<E> create(int bulkPollInterval,
                                              int capacity,
                                              BulkOperationUtil.BulkOperation<E> bulkOperation)

Create based on parameters

Type Parameters:: E - the entity type
Parameters:: bulkPollInterval - the poll interval; capacity - the queue capacity; bulkOperation - the bulk operation itself
Returns:: the created utility

doBulk
```
public void doBulk()
```
Do the bulk operation.

getQueueSize
```
public int getQueueSize()
```
Get the queue size

Returns:

the queue size

add
```
public void add(E e)
```
Add the given element to queue

Parameters:

e - the element to add

stop
```
public void stop()
```
Stop the utility and operate on any remaining elements in queue.

getQueue
```
public BlockingQueue<E> getQueue()
```
Returns:

the queue

getBulkPollInterval
```
public long getBulkPollInterval()
```
Returns:

the bulkPollInterval

getBulkOperation

public BulkOperationUtil.BulkOperation<E> getBulkOperation()

Returns:: the bulkOperation

getDoer

public com.bluejeans.common.utils.BulkOperationUtil.Doer getDoer()

Returns:: the doer

getOfferFailCount
```
public AtomicLong getOfferFailCount()
```
Returns:

the offerFailCount

isStopped
```
public boolean isStopped()
```
Returns:

the stopped

getBatchSize
```
public int getBatchSize()
```
Returns:

the batchSize

setBatchSize
```
public void setBatchSize(int batchSize)
```
Parameters:

batchSize - the batchSize to set

getBulkExecutorSize
```
public int getBulkExecutorSize()
```
Returns:

the bulkExecutorSize

getBulkExecutorQueueCapacity
```
public int getBulkExecutorQueueCapacity()
```
Returns:

the bulkExecutorQueueCapacity

getBulkExecutor

public ThreadPoolExecutor getBulkExecutor()

Returns:: the bulkExecutor

getBulkRunnable
```
public Runnable getBulkRunnable()
```
Returns:

the bulkRunnable

isParallel
```
public boolean isParallel()
```
Returns:

the parallel

setParallel
```
public void setParallel(boolean parallel)
```
Parameters:

parallel - the parallel to set

getMinBatchSize
```
public int getMinBatchSize()
```
Returns:

the minBatchSize

setMinBatchSize
```
public void setMinBatchSize(int minBatchSize)
```
Parameters:

minBatchSize - the minBatchSize to set

Class BulkOperationUtil<E>

Nested Class Summary

Method Summary

Methods inherited from class java.lang.Object

Method Detail

create

create

doBulk

getQueueSize

add

stop

getQueue

getBulkPollInterval

getBulkOperation

getDoer

getOfferFailCount

isStopped

getBatchSize

setBatchSize

getBulkExecutorSize

getBulkExecutorQueueCapacity

getBulkExecutor

getBulkRunnable

isParallel

setParallel

getMinBatchSize

setMinBatchSize