Package | Description |
---|---|
net.sf.ehcache.writer.writebehind |
This package contains the write behind functionalities.
|
net.sf.ehcache.writer.writebehind.operations |
This package contains the operations for the write behind functionalities.
|
Modifier and Type | Field and Description |
---|---|
private java.util.List<SingleOperation> |
WriteBehindQueue.waiting |
Modifier and Type | Method and Description |
---|---|
protected abstract java.util.List<SingleOperation> |
AbstractWriteBehindQueue.quarantineItems()
Quarantine items to be processed.
|
protected java.util.List<SingleOperation> |
WriteBehindQueue.quarantineItems() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractWriteBehindQueue.addItem(SingleOperation operation)
Add an item to the write behind queue
|
protected void |
WriteBehindQueue.addItem(SingleOperation operation) |
Modifier and Type | Method and Description |
---|---|
private int |
AbstractWriteBehindQueue.determineBatchSize(java.util.List<SingleOperation> quarantined) |
private void |
AbstractWriteBehindQueue.filterQuarantined(java.util.List<SingleOperation> quarantined) |
private void |
AbstractWriteBehindQueue.processBatchedOperations(java.util.List<SingleOperation> quarantined) |
private void |
AbstractWriteBehindQueue.processQuarantinedItems(java.util.List<SingleOperation> quarantined) |
private void |
AbstractWriteBehindQueue.processSingleOperation(java.util.List<SingleOperation> quarantined) |
private void |
AbstractWriteBehindQueue.reassemble(java.util.List<SingleOperation> quarantined) |
protected abstract void |
AbstractWriteBehindQueue.reinsertUnprocessedItems(java.util.List<SingleOperation> operations)
Reinsert any unfinished operations into the queue.
|
protected void |
WriteBehindQueue.reinsertUnprocessedItems(java.util.List<SingleOperation> operations) |
private void |
AbstractWriteBehindQueue.waitUntilEnoughTimeHasPassed(java.util.List<SingleOperation> quarantined,
int batchSize,
long secondsSinceLastWorkDone) |
private void |
AbstractWriteBehindQueue.waitUntilEnoughWorkItemsAvailable(java.util.List<SingleOperation> quarantined,
int workSize) |
Modifier and Type | Class and Description |
---|---|
class |
DeleteOperation
Implements the delete operation for write behind
|
class |
WriteOperation
Implements the write operation for write behind
|
Modifier and Type | Method and Description |
---|---|
BatchOperation |
DeleteOperation.createBatchOperation(java.util.List<SingleOperation> operations)
Creates a batch operation that corresponds to the operation type of this single operation.
|
BatchOperation |
WriteOperation.createBatchOperation(java.util.List<SingleOperation> operations)
Creates a batch operation that corresponds to the operation type of this single operation.
|
BatchOperation |
SingleOperation.createBatchOperation(java.util.List<SingleOperation> operations)
Creates a batch operation that corresponds to the operation type of this single operation.
|