public class ScheduledBatcher extends AbstractBatcher
BatchSubmitter.submit(com.usergrid.count.AbstractBatcher.Batch)
every batchInterval seconds.batchSubmitter
Constructor and Description |
---|
ScheduledBatcher(int queueSize,
int batchInterval)
Initializes the scheduledExecutor with the interval (in seconds) at which this executor will fire
|
Modifier and Type | Method and Description |
---|---|
long |
getBatchSubmissionCount() |
protected boolean |
shouldSubmit(com.usergrid.count.AbstractBatcher.Batch batch) |
protected void |
submit(com.usergrid.count.AbstractBatcher.Batch batch) |
add, getOpCount, setBatchSubmitter
public ScheduledBatcher(int queueSize, int batchInterval)
batchInterval
- protected boolean shouldSubmit(com.usergrid.count.AbstractBatcher.Batch batch)
shouldSubmit
in class AbstractBatcher
protected void submit(com.usergrid.count.AbstractBatcher.Batch batch)
submit
in class AbstractBatcher
public long getBatchSubmissionCount()
Copyright © 2013. All Rights Reserved.