public final class DefaultSolrCoreState extends SolrCoreState implements RecoveryStrategy.RecoveryListener
SolrCoreState.IndexWriterCloser
Modifier and Type | Field and Description |
---|---|
protected ReentrantLock |
commitLock |
static org.slf4j.Logger |
log |
closed
Constructor and Description |
---|
DefaultSolrCoreState(DirectoryFactory directoryFactory) |
Modifier and Type | Method and Description |
---|---|
void |
cancelRecovery() |
void |
close(SolrCoreState.IndexWriterCloser closer) |
protected SolrIndexWriter |
createMainIndexWriter(SolrCore core,
String name) |
void |
doRecovery(CoreContainer cc,
CoreDescriptor cd) |
void |
failed() |
Lock |
getCommitLock() |
DirectoryFactory |
getDirectoryFactory() |
RefCounted<IndexWriter> |
getIndexWriter(SolrCore core)
Get the current IndexWriter.
|
void |
newIndexWriter(SolrCore core,
boolean rollback)
Force the creation of a new IndexWriter using the settings from the given
SolrCore.
|
void |
recovered() |
void |
rollbackIndexWriter(SolrCore core)
Rollback the current IndexWriter.
|
decrefSolrCoreState, getUpdateLock, increfSolrCoreState
public static org.slf4j.Logger log
protected final ReentrantLock commitLock
public DefaultSolrCoreState(DirectoryFactory directoryFactory)
public RefCounted<IndexWriter> getIndexWriter(SolrCore core) throws IOException
SolrCoreState
SolrCore
.getIndexWriter
in class SolrCoreState
IOException
- If there is a low-level I/O error.public void newIndexWriter(SolrCore core, boolean rollback) throws IOException
SolrCoreState
newIndexWriter
in class SolrCoreState
rollback
- close IndexWriter if false, else rollbackIOException
- If there is a low-level I/O error.public void rollbackIndexWriter(SolrCore core) throws IOException
SolrCoreState
SolrCore
.rollbackIndexWriter
in class SolrCoreState
IOException
- If there is a low-level I/O error.protected SolrIndexWriter createMainIndexWriter(SolrCore core, String name) throws IOException
IOException
public DirectoryFactory getDirectoryFactory()
getDirectoryFactory
in class SolrCoreState
DirectoryFactory
that should be used.public void doRecovery(CoreContainer cc, CoreDescriptor cd)
doRecovery
in class SolrCoreState
public void cancelRecovery()
cancelRecovery
in class SolrCoreState
public void recovered()
recovered
in interface RecoveryStrategy.RecoveryListener
public void failed()
failed
in interface RecoveryStrategy.RecoveryListener
public void close(SolrCoreState.IndexWriterCloser closer)
close
in class SolrCoreState
public Lock getCommitLock()
getCommitLock
in class SolrCoreState
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.