org.apache.hadoop.hbase.regionserver.wal

Class CustomFSHLog

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.CustomFSHLog

All Implemented Interfaces:

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

class CustomFSHLog
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, org.apache.hadoop.hbase.wal.WAL.Reader

Field Summary

Fields

Modifier and Type	Field and Description
private Boolean	syncFlag
private Boolean	writerSyncFlag

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, 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_SYNC_TIMEOUT_MS, filenum, fs, highestSyncedTxid, highestUnsyncedTxid, implClassName, 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, totalLogSize, useHsync, WAL_ROLL_MULTIPLIER, WAL_SYNC_TIMEOUT_MS, walArchiveDir, walDir, walFile2Props, walFilePrefix, walFileSuffix, writer

Constructor Summary

Constructors

Constructor and Description
CustomFSHLog(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path root, String logDir, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.wal.WALProvider.Writer	createWriterInstance(org.apache.hadoop.fs.Path path)
(package private) Boolean	getSyncFlag()
(package private) Boolean	getWriterSyncFlag()
(package private) void	resetSyncFlag()
void	sync(boolean forceSync)
void	sync(long txid, boolean forceSync)

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

afterCreatingZigZagLatch, append, beforeWaitOnSafePoint, doAppend, doCheckLogLowReplication, doReplaceWriter, doShutdown, getLogReplication, getOutputStream, getPipeline, getSequenceOnRingBuffer, getWriter, isLowReplicationRollEnabled, publishSyncOnRingBuffer, setWriter, sync, sync

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.wal.WAL

getTimestamp

Field Detail

syncFlag

private Boolean syncFlag

writerSyncFlag

private Boolean writerSyncFlag

Constructor Detail

CustomFSHLog

public CustomFSHLog(org.apache.hadoop.fs.FileSystem fs,
                    org.apache.hadoop.fs.Path root,
                    String logDir,
                    org.apache.hadoop.conf.Configuration conf)
             throws IOException

Throws:

IOException

Method Detail

createWriterInstance

protected org.apache.hadoop.hbase.wal.WALProvider.Writer createWriterInstance(org.apache.hadoop.fs.Path path)
                                                                       throws IOException

Overrides:

createWriterInstance in class org.apache.hadoop.hbase.regionserver.wal.FSHLog

Throws:

IOException

sync

public void sync(boolean forceSync)
          throws IOException

Specified by:

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

Overrides:

sync in class org.apache.hadoop.hbase.regionserver.wal.FSHLog

Throws:

IOException

sync

public void sync(long txid,
                 boolean forceSync)
          throws IOException

Specified by:

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

Overrides:

sync in class org.apache.hadoop.hbase.regionserver.wal.FSHLog

Throws:

IOException

resetSyncFlag

void resetSyncFlag()

getSyncFlag

Boolean getSyncFlag()

getWriterSyncFlag

Boolean getWriterSyncFlag()