org.apache.hadoop.hbase.wal

Class FaultyFSLog

java.lang.Object

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

org.apache.hadoop.hbase.wal.FaultyFSLog

All Implemented Interfaces:

WAL

@InterfaceAudience.Private
public class FaultyFSLog
extends FSHLog

This is a utility class, used by tests, which fails operation specified by FailureType enum

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FaultyFSLog.FailureType

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

WAL.Entry, WAL.Reader

Field Summary

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

conf, FIXED_OVERHEAD, fs

Constructor Summary

Constructors

Constructor and Description
FaultyFSLog(FileSystem fs, Path rootDir, String logName, Configuration conf)

Method Summary

Modifier and Type	Method and Description
long	append(HTableDescriptor htd, HRegionInfo info, WALKey key, WALEdit edits, AtomicLong sequenceId, boolean isInMemstore, List<Cell> cells) Append a set of edits to the WAL.
void	setFailureType(FaultyFSLog.FailureType fType)
void	sync(long txid) Sync the WAL if the txId was not already sync'd.

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

abortCacheFlush, afterCreatingZigZagLatch, beforeWaitOnSafePoint, close, completeCacheFlush, computeFilename, createWriterInstance, getCoprocessorHost, getCurrentFileName, getEarliestMemstoreSeqNum, getEarliestMemstoreSeqNum, getFileNumFromFileName, getFiles, getLogFileSize, getNumLogFiles, getNumRolledLogFiles, getWALArchivePath, main, makeKey, registerWALActionsListener, requestLogRoll, rollWriter, rollWriter, shutdown, startCacheFlush, sync, toString, unregisterWALActionsListener

Methods inherited from class java.lang.Object

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

Constructor Detail

FaultyFSLog

public FaultyFSLog(FileSystem fs,
                   Path rootDir,
                   String logName,
                   Configuration conf)
            throws IOException

Throws:

IOException

Method Detail

setFailureType

public void setFailureType(FaultyFSLog.FailureType fType)

sync

public void sync(long txid)
          throws IOException

Description copied from interface: WAL

Sync the WAL if the txId was not already sync'd.

Specified by:

sync in interface WAL

Overrides:

sync in class FSHLog

Parameters:

txid - Transaction id to sync to.

Throws:

IOException

append

public long append(HTableDescriptor htd,
                   HRegionInfo info,
                   WALKey key,
                   WALEdit edits,
                   AtomicLong sequenceId,
                   boolean isInMemstore,
                   List<Cell> cells)
            throws IOException

Description copied from interface: WAL

Append a set of edits to the WAL. The WAL is not flushed/sync'd after this transaction completes BUT on return this edit must have its region edit/sequence id assigned else it messes up our unification of mvcc and sequenceid. On return key will have the region edit/sequence id filled in.

Specified by:

append in interface WAL

Overrides:

append in class FSHLog

Parameters:

htd - used to give scope for replication TODO refactor out in favor of table name and info

key - Modified by this call; we add to it this edits region edit/sequence id.

edits - Edits to append. MAY CONTAIN NO EDITS for case where we want to get an edit sequence id that is after all currently appended edits.

sequenceId - A reference to the atomic long the info region is using as source of its incrementing edits sequence id. Inside in this call we will increment it and attach the sequence to the edit we apply the WAL.

isInMemstore - Always true except for case where we are writing a compaction completion record into the WAL; in this case the entry is just so we can finish an unfinished compaction -- it is not an edit for memstore.

cells - list of KVs added into memstore

Returns:

Returns a 'transaction id' and key will have the region edit/sequence id in it.

Throws:

IOException