static class BrokenRemoteAsyncFSWALProvider.BrokenRemoteAsyncFSWAL extends org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
Modifier and Type | Class and Description |
---|---|
private class |
BrokenRemoteAsyncFSWALProvider.BrokenRemoteAsyncFSWAL.MyCombinedAsyncWriter |
Modifier and Type | Field and Description |
---|---|
private CountDownLatch |
arrive |
private boolean |
localBroken |
private boolean |
remoteBroken |
private CountDownLatch |
resume |
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
abortable, blocksize, closed, closeExecutor, conf, consumeExecutor, consumer, 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, hasConsumerTask, highestProcessedAppendTxid, highestSyncedTxid, highestUnsyncedTxid, implClassName, inflightWALClosures, listeners, logrollsize, MAX_LOGS, maxLogs, numEntries, ourFiles, prefixPathStr, RING_BUFFER_SLOT_COUNT, ROLL_ON_SYNC_TIME_MS, rollOnSyncNs, rollRequested, rollWriterLock, sequenceIdAccounting, shouldShutDownConsumeExecutorWhenClose, shutdown, SLOW_SYNC_ROLL_INTERVAL_MS, SLOW_SYNC_ROLL_THRESHOLD, SLOW_SYNC_TIME_MS, slowSyncCheckInterval, slowSyncCount, slowSyncNs, slowSyncRollThreshold, syncFutureCache, syncFutures, totalLogSize, toWriteAppends, unackedAppends, 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
Constructor and Description |
---|
BrokenRemoteAsyncFSWAL(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.hbase.Abortable abortable,
org.apache.hadoop.fs.Path rootDir,
String logDir,
String archiveDir,
org.apache.hadoop.conf.Configuration conf,
List<org.apache.hadoop.hbase.regionserver.wal.WALActionsListener> listeners,
boolean failIfWALExists,
String prefix,
String suffix,
org.apache.hadoop.fs.FileSystem remoteFs,
org.apache.hadoop.fs.Path remoteWALDir,
org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass,
org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter |
createCombinedWriter(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter localWriter,
org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter remoteWriter) |
protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter |
createWriterInstance(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path) |
void |
resumeLogRoll() |
void |
setLocalBroken() |
void |
setRemoteBroken() |
void |
suspendLogRoll() |
void |
waitUntilArrive() |
createAsyncWriter, doAppend, doCheckLogLowReplication, doWriterSync, onWriterReplaced
abortCacheFlush, append, appendData, appendEntry, appendMarker, archive, archiveLogFile, atHeadOfRingBufferEventHandlerAppend, blockOnSync, checkLogLowReplication, checkSlowSyncCount, close, closeWriter, completeCacheFlush, computeFilename, createSingleThreadPoolConsumeExecutor, doCheckSlowSync, doCleanUpResources, doReplaceWriter, doShutdown, doSync, doSync, getCoprocessorHost, getCurrentFileName, getEarliestMemStoreSeqNum, getEarliestMemStoreSeqNum, getFilenum, getFileNumFromFileName, getInflightWALCloseCount, getLogFileSize, getLogFileSizeIfBeingWritten, getNumLogFiles, getNumRolledLogFiles, getOldPath, getPreallocatedEventCount, getSyncedTxid, getSyncFuture, getWALArchivePath, init, isLogRollRequested, isWriterBroken, logRollAndSetupWalProps, main, markFutureDoneAndOffer, postSync, registerWALActionsListener, requestLogRoll, requestLogRoll, rollWriter, rollWriter, setWaitOnShutdownInSeconds, shutdown, skipRemoteWAL, stampSequenceIdAndPublishToRingBuffer, startCacheFlush, startCacheFlush, sync, sync, sync, sync, toString, unregisterWALActionsListener, updateStore, waitForSafePoint
private volatile boolean localBroken
private volatile boolean remoteBroken
private CountDownLatch arrive
private CountDownLatch resume
public BrokenRemoteAsyncFSWAL(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.Abortable abortable, org.apache.hadoop.fs.Path rootDir, String logDir, String archiveDir, org.apache.hadoop.conf.Configuration conf, List<org.apache.hadoop.hbase.regionserver.wal.WALActionsListener> listeners, boolean failIfWALExists, String prefix, String suffix, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass, org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor monitor) throws org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException, IOException
org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException
IOException
public void setLocalBroken()
public void setRemoteBroken()
public void suspendLogRoll()
public void waitUntilArrive() throws InterruptedException
InterruptedException
public void resumeLogRoll()
protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter createCombinedWriter(org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter localWriter, org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter remoteWriter)
createCombinedWriter
in class org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
protected org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter createWriterInstance(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException
createWriterInstance
in class org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.