Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.util | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Method and Description |
---|---|
static WAL |
HBaseTestingUtility.createWal(Configuration conf,
Path rootDir,
Path walRootDir,
HRegionInfo hri)
Create an unmanaged WAL.
|
WAL |
MockRegionServerServices.getWAL(HRegionInfo regionInfo) |
Modifier and Type | Method and Description |
---|---|
HRegion |
HBaseTestingUtility.createLocalHRegion(byte[] tableName,
byte[] startKey,
byte[] stopKey,
java.lang.String callingMethod,
Configuration conf,
boolean isReadOnly,
Durability durability,
WAL wal,
byte[]... families) |
HRegion |
HBaseTestingUtility.createLocalHRegion(HRegionInfo info,
HTableDescriptor desc,
WAL wal)
Create an HRegion that writes to the local tmp dirs with specified wal
|
Modifier and Type | Method and Description |
---|---|
WAL |
WALCoprocessorEnvironment.getWAL() |
Constructor and Description |
---|
CompactionCompletionNotifyingRegion(Path tableDir,
WAL log,
FileSystem fs,
Configuration confParam,
HRegionInfo info,
HTableDescriptor htd,
RegionServerServices rsServices) |
Modifier and Type | Method and Description |
---|---|
WAL |
HRegion.getWAL() |
WAL |
HRegionServer.getWAL(HRegionInfo regionInfo) |
WAL |
RegionServerServices.getWAL(HRegionInfo regionInfo) |
Modifier and Type | Method and Description |
---|---|
void |
LogRoller.addWAL(WAL wal) |
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal) |
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize)
Convenience method creating new HRegions.
|
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize,
boolean ignoreWAL)
Convenience method creating new HRegions.
|
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Path tableDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize,
boolean ignoreWAL)
Convenience method creating new HRegions.
|
protected long |
HRegion.getNextSequenceId(WAL wal)
Method to safely get the next sequence number.
|
static HRegion |
TestHRegion.initHRegion(byte[] tableName,
byte[] startKey,
byte[] stopKey,
java.lang.String callingMethod,
Configuration conf,
boolean isReadOnly,
Durability durability,
WAL wal,
byte[]... families) |
HRegion |
TestFailedAppendAndSync.initHRegion(TableName tableName,
byte[] startKey,
byte[] stopKey,
WAL wal) |
protected Region.FlushResult |
HRegion.internalFlushcache(WAL wal,
long myseqid,
java.util.Collection<Store> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker)
Flush the memstore.
|
protected Region.FlushResult |
HRegion.internalFlushCacheAndCommit(WAL wal,
MonitoredTask status,
org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult prepareResult,
java.util.Collection<Store> storesToFlush) |
protected org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult |
HRegion.internalPrepareFlushCache(WAL wal,
long myseqid,
java.util.Collection<Store> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker) |
static HRegion |
HRegion.openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal)
Open a Region.
|
static HRegion |
HRegion.openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
Path tableDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf)
Open a Region.
|
static HRegion |
HRegion.openHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf)
Open a Region.
|
static HRegion |
HRegion.openHRegion(Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static void |
HRegion.warmupHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter) |
Constructor and Description |
---|
HRegion(HRegionFileSystem fs,
WAL wal,
Configuration confParam,
HTableDescriptor htd,
RegionServerServices rsServices)
HRegion constructor.
|
HRegion(Path tableDir,
WAL wal,
FileSystem fs,
Configuration confParam,
HRegionInfo regionInfo,
HTableDescriptor htd,
RegionServerServices rsServices)
Deprecated.
|
MockHRegion(Path tableDir,
WAL log,
FileSystem fs,
Configuration conf,
HRegionInfo regionInfo,
HTableDescriptor htd,
RegionServerServices rsServices) |
Modifier and Type | Class and Description |
---|---|
class |
FSHLog
Implementation of
WAL to go against FileSystem ; i.e. |
Modifier and Type | Method and Description |
---|---|
static long |
WALUtil.writeBulkLoadMarkerAndSync(WAL wal,
HTableDescriptor htd,
HRegionInfo info,
WALProtos.BulkLoadDescriptor descriptor,
java.util.concurrent.atomic.AtomicLong sequenceId)
Write a log marker that a bulk load has succeeded and is about to be committed.
|
static void |
WALUtil.writeCompactionMarker(WAL log,
HTableDescriptor htd,
HRegionInfo info,
WALProtos.CompactionDescriptor c,
java.util.concurrent.atomic.AtomicLong sequenceId)
Write the marker that a compaction has succeeded and is about to be committed.
|
static long |
WALUtil.writeFlushMarker(WAL log,
HTableDescriptor htd,
HRegionInfo info,
WALProtos.FlushDescriptor f,
java.util.concurrent.atomic.AtomicLong sequenceId,
boolean sync)
Write a flush marker indicating a start / abort or a complete of a region flush
|
static long |
WALUtil.writeRegionEventMarker(WAL log,
HTableDescriptor htd,
HRegionInfo info,
WALProtos.RegionEventDescriptor r,
java.util.concurrent.atomic.AtomicLong sequenceId)
Write a region open marker indicating that the region is opened
|
Constructor and Description |
---|
WALCoprocessorHost(WAL log,
Configuration conf)
Constructor
|
Modifier and Type | Method and Description |
---|---|
WAL |
MetaUtils.getLog(HRegionInfo info) |
Modifier and Type | Method and Description |
---|---|
WAL |
WALFactory.getMetaWAL(byte[] identifier) |
WAL |
DefaultWALProvider.getWAL(byte[] identifier) |
WAL |
WALFactory.getWAL(byte[] identifier) |
WAL |
WALProvider.getWAL(byte[] identifier) |
Modifier and Type | Method and Description |
---|---|
static long |
DefaultWALProvider.extractFileNumFromWAL(WAL wal)
It returns the file create timestamp from the file name.
|
static Path |
DefaultWALProvider.getCurrentFileName(WAL wal)
return the current filename from the current wal.
|
static int |
DefaultWALProvider.getNumRolledLogFiles(WAL wal)
returns the number of rolled WAL files.
|