public abstract class AbstractBatcher extends Object implements Batcher
Modifier and Type | Field and Description |
---|---|
protected BatchSubmitter |
batchSubmitter |
Constructor and Description |
---|
AbstractBatcher(int queueSize) |
Modifier and Type | Method and Description |
---|---|
void |
add(Count count)
Add a count object to this batcher
|
long |
getOpCount()
Individual
Count for the same counter get rolled up, so
we track the individual number of operations. |
void |
setBatchSubmitter(BatchSubmitter batchSubmitter) |
protected abstract boolean |
shouldSubmit(com.usergrid.count.AbstractBatcher.Batch batch) |
protected abstract void |
submit(com.usergrid.count.AbstractBatcher.Batch batch) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getBatchSubmissionCount
protected BatchSubmitter batchSubmitter
public void setBatchSubmitter(BatchSubmitter batchSubmitter)
setBatchSubmitter
in interface Batcher
public long getOpCount()
Count
for the same counter get rolled up, so
we track the individual number of operations.getOpCount
in interface Batcher
protected abstract boolean shouldSubmit(com.usergrid.count.AbstractBatcher.Batch batch)
protected abstract void submit(com.usergrid.count.AbstractBatcher.Batch batch)
public void add(Count count) throws CounterProcessingUnavailableException
add
in interface Batcher
count
- CounterProcessingUnavailableException
Copyright © 2013. All Rights Reserved.