Package org.apache.hadoop.hbase.regionserver.wal

Class AbstractTestWALReplay.MockWAL

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.Writer>

org.apache.hadoop.hbase.regionserver.wal.FSHLog

org.apache.hadoop.hbase.regionserver.wal.AbstractTestWALReplay.MockWAL

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider, org.apache.hadoop.hbase.wal.WAL

Enclosing class:

AbstractTestWALReplay

static class AbstractTestWALReplay.MockWAL
extends org.apache.hadoop.hbase.regionserver.wal.FSHLog

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.wal.FSHLog

org.apache.hadoop.hbase.regionserver.wal.FSHLog.RingBufferEventHandler, org.apache.hadoop.hbase.regionserver.wal.FSHLog.RingBufferExceptionHandler, org.apache.hadoop.hbase.regionserver.wal.FSHLog.SafePointZigZagLatch

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.wal.WAL

org.apache.hadoop.hbase.wal.WAL.Entry

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	doCompleteCacheFlush

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.FSHLog

FIXED_OVERHEAD

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL

abortable, blocksize, closed, closeExecutor, conf, coprocessorHost, DEFAULT_ROLL_ON_SYNC_TIME_MS, DEFAULT_SLOW_SYNC_ROLL_INTERVAL_MS, DEFAULT_SLOW_SYNC_ROLL_THRESHOLD, DEFAULT_SLOW_SYNC_TIME_MS, DEFAULT_WAL_SHUTDOWN_WAIT_TIMEOUT_MS, DEFAULT_WAL_SYNC_TIMEOUT_MS, filenum, fs, highestSyncedTxid, highestUnsyncedTxid, implClassName, inflightWALClosures, listeners, LOG_NAME_COMPARATOR, logrollsize, MAX_LOGS, maxLogs, numEntries, ourFiles, prefixPathStr, RING_BUFFER_SLOT_COUNT, ROLL_ON_SYNC_TIME_MS, rollOnSyncNs, rollRequested, rollWriterLock, sequenceIdAccounting, shutdown, SLOW_SYNC_ROLL_INTERVAL_MS, SLOW_SYNC_ROLL_THRESHOLD, SLOW_SYNC_TIME_MS, slowSyncCheckInterval, slowSyncCount, slowSyncNs, slowSyncRollThreshold, syncFutureCache, totalLogSize, useHsync, WAL_AVOID_LOCAL_WRITES_DEFAULT, WAL_AVOID_LOCAL_WRITES_KEY, WAL_ROLL_MULTIPLIER, WAL_SHUTDOWN_WAIT_TIMEOUT_MS, WAL_SYNC_TIMEOUT_MS, walArchiveDir, walDir, walFile2Props, walFilePrefix, walFileSuffix, walShutdownTimeout, writer

Constructor Summary

Constructors

Constructor	Description
MockWAL(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, String logName, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	completeCacheFlush(byte[] encodedRegionName, long maxFlushedSeqId)

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.FSHLog

afterCreatingZigZagLatch, append, beforeWaitOnSafePoint, createWriterInstance, doAppend, doCheckLogLowReplication, doReplaceWriter, doShutdown, doSync, doSync, getLogReplication, getOutputStream, getPipeline, getSequenceOnRingBuffer, isLowReplicationRollEnabled, publishSyncOnRingBuffer

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL

abortCacheFlush, appendData, appendEntry, appendMarker, archive, archiveLogFile, atHeadOfRingBufferEventHandlerAppend, blockOnSync, checkLogLowReplication, close, computeFilename, doCheckSlowSync, findRegionsToForceFlush, getCoprocessorHost, getCurrentFileName, getEarliestMemStoreSeqNum, getEarliestMemStoreSeqNum, getFilenum, getFileNumFromFileName, getFiles, getInflightWALCloseCount, getLogFileSize, getLogFileSizeIfBeingWritten, getNumLogFiles, getNumRolledLogFiles, getOldPath, getPreallocatedEventCount, getSyncFuture, getUnflushedEntriesCount, getWALArchivePath, getWriter, init, isLogRollRequested, isUnflushedEntries, logRollAndSetupWalProps, main, markClosedAndClean, postSync, registerWALActionsListener, replaceWriter, requestLogRoll, requestLogRoll, rollWriter, rollWriter, shutdown, stampSequenceIdAndPublishToRingBuffer, startCacheFlush, startCacheFlush, sync, sync, sync, sync, toString, unregisterWALActionsListener, updateStore

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

doCompleteCacheFlush

boolean doCompleteCacheFlush

Constructor Details

MockWAL

public MockWAL(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path rootDir,
 String logName,
 org.apache.hadoop.conf.Configuration conf)
        throws IOException

Throws:

IOException

Method Details

completeCacheFlush

public void completeCacheFlush(byte[] encodedRegionName,
 long maxFlushedSeqId)

Specified by:

completeCacheFlush in interface org.apache.hadoop.hbase.wal.WAL

Overrides:

completeCacheFlush in class org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL<org.apache.hadoop.hbase.wal.WALProvider.Writer>