org.apache.hadoop.hbase.regionserver.wal

Class CustomAsyncFSWAL

java.lang.Object

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

org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL

org.apache.hadoop.hbase.regionserver.wal.CustomAsyncFSWAL

All Implemented Interfaces:

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

class CustomAsyncFSWAL
extends org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL

Nested Class Summary

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

ASYNC_WAL_USE_SHARED_EVENT_LOOP, ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS, DEFAULT_ASYNC_WAL_USE_SHARED_EVENT_LOOP, DEFAULT_ASYNC_WAL_WAIT_ON_SHUTDOWN_IN_SECONDS, DEFAULT_WAL_BATCH_SIZE, WAL_BATCH_SIZE

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
CustomAsyncFSWAL(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, String logDir, org.apache.hadoop.conf.Configuration conf, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter	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.AsyncFSWAL

append, closeWriter, doAppend, doCheckLogLowReplication, doReplaceWriter, doShutdown, getLogReplication, getPipeline, 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

CustomAsyncFSWAL

public CustomAsyncFSWAL(org.apache.hadoop.fs.FileSystem fs,
                        org.apache.hadoop.fs.Path rootDir,
                        String logDir,
                        org.apache.hadoop.conf.Configuration conf,
                        org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
                        Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)
                 throws org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException,
                        IOException

Throws:

org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException

IOException

Method Detail

createWriterInstance

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

Overrides:

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

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

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

Throws:

IOException

resetSyncFlag

void resetSyncFlag()

getSyncFlag

Boolean getSyncFlag()

getWriterSyncFlag

Boolean getWriterSyncFlag()