final class CommitTracker
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicInteger |
autoCommitCount |
private SolrCore |
core |
int |
DOC_COMMIT_DELAY_MS |
private java.util.concurrent.atomic.AtomicLong |
docsSinceCommit |
private int |
docsUpperBound |
protected static org.slf4j.Logger |
log |
private java.lang.String |
name |
private java.util.concurrent.ScheduledFuture |
pending |
private java.util.concurrent.ScheduledExecutorService |
scheduler |
private boolean |
softCommit |
private long |
timeUpperBound |
private boolean |
waitSearcher |
Constructor and Description |
---|
CommitTracker(java.lang.String name,
SolrCore core,
int docsUpperBound,
int timeUpperBound,
boolean waitSearcher,
boolean softCommit) |
Modifier and Type | Method and Description |
---|---|
private void |
_scheduleCommitWithin(long commitMaxTime) |
private void |
_scheduleCommitWithinIfNeeded(long commitWithin) |
void |
addedDocument(int commitWithin)
Indicate that documents have been added
|
void |
close() |
void |
deletedDocument(int commitWithin)
Indicate that documents have been deleted
|
void |
didCommit()
Inform tracker that a commit has occurred
|
void |
didRollback()
Inform tracker that a rollback has occurred, cancel any pending commits
|
int |
getCommitCount() |
(package private) int |
getDocsUpperBound() |
long |
getTimeUpperBound() |
void |
run()
This is the worker part for the ScheduledFuture
|
void |
scheduleCommitWithin(long commitMaxTime)
schedule individual commits
|
(package private) void |
setDocsUpperBound(int docsUpperBound) |
(package private) void |
setTimeUpperBound(long timeUpperBound) |
java.lang.String |
toString() |
protected static final org.slf4j.Logger log
public final int DOC_COMMIT_DELAY_MS
private int docsUpperBound
private long timeUpperBound
private final java.util.concurrent.ScheduledExecutorService scheduler
private java.util.concurrent.ScheduledFuture pending
private java.util.concurrent.atomic.AtomicLong docsSinceCommit
private java.util.concurrent.atomic.AtomicInteger autoCommitCount
private final SolrCore core
private final boolean softCommit
private final boolean waitSearcher
private java.lang.String name
public CommitTracker(java.lang.String name, SolrCore core, int docsUpperBound, int timeUpperBound, boolean waitSearcher, boolean softCommit)
public void close()
public void scheduleCommitWithin(long commitMaxTime)
private void _scheduleCommitWithinIfNeeded(long commitWithin)
private void _scheduleCommitWithin(long commitMaxTime)
public void addedDocument(int commitWithin)
public void deletedDocument(int commitWithin)
public void didCommit()
public void didRollback()
public void run()
run
in interface java.lang.Runnable
public int getCommitCount()
public java.lang.String toString()
toString
in class java.lang.Object
public long getTimeUpperBound()
int getDocsUpperBound()
void setDocsUpperBound(int docsUpperBound)
void setTimeUpperBound(long timeUpperBound)