A B C D E F G I L M N P R S

A

append(byte[]) - Method in class com.bluejeans.common.bigqueue.BigArray

Append the data into the head of the array

applyForEach(ItemIterator) - Method in class com.bluejeans.common.bigqueue.BigQueue

B

BigArray - Class in com.bluejeans.common.bigqueue

A big array implementation supporting sequential append and random read.

BigArray(String, String) - Constructor for class com.bluejeans.common.bigqueue.BigArray

A big array implementation supporting sequential write and random read, use default back data file size per page, see DEFAULT_DATA_PAGE_SIZE.

BigArray(String, String, int) - Constructor for class com.bluejeans.common.bigqueue.BigArray

A big array implementation supporting sequential write and random read.

BigQueue - Class in com.bluejeans.common.bigqueue

A big, fast and persistent queue implementation.

BigQueue(String, String) - Constructor for class com.bluejeans.common.bigqueue.BigQueue

A big, fast and persistent queue implementation, use default back data page size, see DEFAULT_DATA_PAGE_SIZE

BigQueue(String, String, int) - Constructor for class com.bluejeans.common.bigqueue.BigQueue

A big, fast and persistent queue implementation.

BigQueueException - Exception in com.bluejeans.common.bigqueue

BigQueueException(String) - Constructor for exception com.bluejeans.common.bigqueue.BigQueueException

BigQueueException(Exception) - Constructor for exception com.bluejeans.common.bigqueue.BigQueueException

C

close() - Method in class com.bluejeans.common.bigqueue.BigArray

close() - Method in class com.bluejeans.common.bigqueue.BigQueue

close() - Method in class com.bluejeans.common.bigqueue.FanOutQueue

com.bluejeans.common.bigqueue - package com.bluejeans.common.bigqueue

D

DEFAULT_DATA_PAGE_SIZE - Static variable in class com.bluejeans.common.bigqueue.BigArray

dequeue() - Method in class com.bluejeans.common.bigqueue.BigQueue

Retrieves and removes the front of a queue

dequeue(String) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Retrieves and removes the front of a fan out queue

dequeueAsync() - Method in class com.bluejeans.common.bigqueue.BigQueue

Retrieves a Future which will complete if new Items where enqued.

dequeueMulti(int) - Method in class com.bluejeans.common.bigqueue.BigQueue

Retrieves and removes the fronts of a queue upto given total number / total size whichever is smaller

E

EARLIEST - Static variable in class com.bluejeans.common.bigqueue.FanOutQueue

Constant represents earliest timestamp

enqueue(byte[]) - Method in class com.bluejeans.common.bigqueue.BigQueue

Adds an item at the back of a queue

enqueue(byte[]) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Adds an item at the back of the queue

F

FanOutQueue - Class in com.bluejeans.common.bigqueue

A big, fast and persistent queue implementation supporting fan out semantics.

FanOutQueue(String, String, int) - Constructor for class com.bluejeans.common.bigqueue.FanOutQueue

A big, fast and persistent queue implementation with fandout support.

FanOutQueue(String, String) - Constructor for class com.bluejeans.common.bigqueue.FanOutQueue

A big, fast and persistent queue implementation with fanout support, use default back data page size, see DEFAULT_DATA_PAGE_SIZE

findClosestIndex(long) - Method in class com.bluejeans.common.bigqueue.BigArray

Find an index closest to the specific timestamp when the corresponding item was appended

findClosestIndex(long) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Find an index closest to the specific timestamp when the corresponding item was enqueued.

flush() - Method in class com.bluejeans.common.bigqueue.BigArray

Force to persist newly appended data, normally, you don't need to flush explicitly since: 1.) BigArray will automatically flush a cached page when it is replaced out, 2.) BigArray uses memory mapped file technology internally, and the OS will flush the changes even your process crashes, call this periodically only if you need transactional reliability and you are aware of the cost to performance.

flush() - Method in class com.bluejeans.common.bigqueue.BigQueue

Force to persist current state of the queue, normally, you don't need to flush explicitly since: 1.) BigQueue will automatically flush a cached page when it is replaced out, 2.) BigQueue uses memory mapped file technology internally, and the OS will flush the changes even your process crashes, call this periodically only if you need transactional reliability and you are aware of the cost to performance.

flush() - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Force to persist current state of the queue, normally, you don't need to flush explicitly since: 1.) FanOutQueue will automatically flush a cached page when it is replaced out, 2.) FanOutQueue uses memory mapped file technology internally, and the OS will flush the changes even your process crashes, call this periodically only if you need transactional reliability and you are aware of the cost to performance.

forEach(byte[]) - Method in interface com.bluejeans.common.bigqueue.ItemIterator

G

gc() - Method in class com.bluejeans.common.bigqueue.BigQueue

Delete all used data files to free disk space.

get(long) - Method in class com.bluejeans.common.bigqueue.BigArray

Get the data at specific index

get(long) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Retrieves data item at the specific index of the queue

getBackFileSize() - Method in class com.bluejeans.common.bigqueue.BigArray

Get total size of back files(index and data files) of the big array

getBackFileSize() - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Current total size of the back files of this queue

getDataPageSize() - Method in class com.bluejeans.common.bigqueue.BigArray

Get the back data file size per page.

getFrontIndex() - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Get the queue front index, this is the earliest appended index

getFrontIndex(String) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

getHeadIndex() - Method in class com.bluejeans.common.bigqueue.BigArray

The head of the array.

getItemLength(long) - Method in class com.bluejeans.common.bigqueue.BigArray

Get the data item length at specific index

getLength(long) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Get length of data item at specific index of the queue

getRearIndex() - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Get the queue rear index, this is the next to be appended index

getTailIndex() - Method in class com.bluejeans.common.bigqueue.BigArray

The tail of the array.

getTimestamp(long) - Method in class com.bluejeans.common.bigqueue.BigArray

Get the timestamp of data at specific index, this is the timestamp when the data was appended.

getTimestamp(long) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Get timestamp of data item at specific index of the queue, this is the timestamp when corresponding item was appended into the queue.

I

isEmpty() - Method in class com.bluejeans.common.bigqueue.BigArray

Check if the array is empty or not

isEmpty() - Method in class com.bluejeans.common.bigqueue.BigQueue

Determines whether a queue is empty

isEmpty(String) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

isEmpty() - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Determines whether the queue is empty

isFull() - Method in class com.bluejeans.common.bigqueue.BigArray

Check if the ring space of java long type has all been used up.

ItemIterator - Interface in com.bluejeans.common.bigqueue

Item iterator interface

L

LATEST - Static variable in class com.bluejeans.common.bigqueue.FanOutQueue

Constant represents latest timestamp

limitBackFileSize(long) - Method in class com.bluejeans.common.bigqueue.BigArray

limit the back file size, truncate back file and advance array tail index accordingly, Note, this is a best effort call, exact size limit can't be guaranteed

limitBackFileSize(long) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Limit the back file size of this queue, truncate back files and advance the queue front if necessary.

M

MINIMUM_DATA_PAGE_SIZE - Static variable in class com.bluejeans.common.bigqueue.BigArray

N

NOT_FOUND - Static variable in class com.bluejeans.common.bigqueue.BigArray

P

peek() - Method in class com.bluejeans.common.bigqueue.BigQueue

Retrieves the item at the front of a queue

peek(String) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Peek the item at the front of a fanout queue, without removing it from the queue

peekAsync() - Method in class com.bluejeans.common.bigqueue.BigQueue

Retrieves the item at the front of a queue asynchronously.

peekLength(String) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Peek the length of the item at the front of a fan out queue

peekMulti(int) - Method in class com.bluejeans.common.bigqueue.BigQueue

Retrieves the items at the front of a queue

peekTimestamp(String) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Peek the timestamp of the item at the front of a fan out queue

R

removeAll() - Method in class com.bluejeans.common.bigqueue.BigArray

removeAll() - Method in class com.bluejeans.common.bigqueue.BigQueue

Removes all items of a queue, this will empty the queue and delete all back data files.

removeAll() - Method in class com.bluejeans.common.bigqueue.FanOutQueue

removeBefore(long) - Method in class com.bluejeans.common.bigqueue.BigArray

Remove all data before specific timestamp, this will advance the array tail and delete back page files accordingly.

removeBefore(long) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Remove all data before specific timestamp, truncate back files and advance the queue front if necessary.

removeBeforeIndex(long) - Method in class com.bluejeans.common.bigqueue.BigArray

Remove all data before specific index, this will advance the array tail to index and delete back page files before index.

resetQueueFrontIndex(String, long) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

S

size() - Method in class com.bluejeans.common.bigqueue.BigArray

The total number of items has been appended into the array

size() - Method in class com.bluejeans.common.bigqueue.BigQueue

Total number of items available in the queue.

size(String) - Method in class com.bluejeans.common.bigqueue.FanOutQueue

size() - Method in class com.bluejeans.common.bigqueue.FanOutQueue

Total number of items remaining in the queue.

A B C D E F G I L M N P R S