public class HdfsUpdateLog extends UpdateLog
UpdateLog.DBQ, UpdateLog.LogPtr, UpdateLog.RecentUpdates, UpdateLog.RecoveryInfo, UpdateLog.State, UpdateLog.SyncLevelADD, cancelApplyBufferUpdate, COMMIT, dataDir, debug, defaultSyncLevel, DELETE, DELETE_BY_QUERY, deleteByQueries, FLAG_GAP, globalStrings, lastDataDir, log, LOG_FILENAME_PATTERN, logs, map, newestLogsOnStartup, numDeletesByQueryToKeep, numDeletesToKeep, numOldRecords, numRecordsToKeep, oldDeletes, OPERATION_MASK, operationFlags, prevMap, prevMap2, prevMapLog, prevMapLog2, prevTlog, recoveryInfo, state, testing_logReplayFinishHook, testing_logReplayHook, tlog, TLOG_NAME, tlogFiles, trace, versionInfo| Constructor and Description |
|---|
HdfsUpdateLog() |
HdfsUpdateLog(String confDir) |
| Modifier and Type | Method and Description |
|---|---|
void |
clearLog(SolrCore core,
PluginInfo ulogPluginInfo)
Clears the logs on the file system.
|
void |
close(boolean committed) |
void |
close(boolean committed,
boolean deleteOnClose) |
boolean |
dropBufferedUpdates()
Returns true if we were able to drop buffered updates and return to the ACTIVE state
|
protected void |
ensureLog() |
String |
getLogDir() |
static String[] |
getLogList(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tlogDir) |
void |
init(PluginInfo info) |
void |
init(UpdateHandler uhandler,
SolrCore core) |
String |
toString()
Returns true if we were able to drop buffered updates and return to the
ACTIVE state
|
add, add, addOldLog, applyBufferedUpdates, bufferUpdates, cancelApplyBufferedUpdates, delete, deleteAll, deleteByQuery, deleteFile, finish, getDBQNewer, getFs, getLastLogId, getLogList, getRecentUpdates, getStartingOperation, getStartingVersions, getState, getTlogDir, getTotalLogsNumber, getTotalLogsSize, getVersionInfo, hasUncommittedChanges, lookup, lookupVersion, newMap, postCommit, postSoftCommit, preCommit, preSoftCommit, recoverFromLogpublic HdfsUpdateLog()
public HdfsUpdateLog(String confDir)
public boolean dropBufferedUpdates()
UpdateLogdropBufferedUpdates in class UpdateLogpublic void init(PluginInfo info)
init in interface PluginInfoInitializedinit in class UpdateLogpublic void init(UpdateHandler uhandler, SolrCore core)
public static String[] getLogList(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path tlogDir)
public void close(boolean committed,
boolean deleteOnClose)
public void clearLog(SolrCore core, PluginInfo ulogPluginInfo)
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.