Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.master.region | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Method and Description |
---|---|
WAL |
WALCoprocessorEnvironment.getWAL()
Returns reference to the region server's WAL
|
Modifier and Type | Method and Description |
---|---|
private static WAL |
MasterRegion.createWAL(WALFactory walFactory,
MasterRegionWALRoller walRoller,
String serverName,
org.apache.hadoop.fs.FileSystem walFs,
org.apache.hadoop.fs.Path walRootDir,
RegionInfo regionInfo) |
Modifier and Type | Field and Description |
---|---|
private WAL |
HRegion.wal |
Modifier and Type | Method and Description |
---|---|
WAL |
RegionServicesForStores.getWAL() |
WAL |
HRegion.getWAL()
Returns WAL in use for this region
|
WAL |
RegionServerServices.getWAL(RegionInfo regionInfo)
Returns the WAL for a particular region.
|
WAL |
HRegionServer.getWAL(RegionInfo regionInfo) |
Modifier and Type | Method and Description |
---|---|
(package private) Map<WAL,AbstractWALRoller.RollController> |
LogRoller.getWalNeedsRoll() |
List<WAL> |
RegionServerServices.getWALs()
Returns the List of WALs that are used by this server Doesn't include the meta WAL
|
List<WAL> |
HRegionServer.getWALs() |
Modifier and Type | Method and Description |
---|---|
static HRegion |
HRegion.createHRegion(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor hTableDescriptor,
WAL wal) |
static HRegion |
HRegion.createHRegion(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor hTableDescriptor,
WAL wal,
boolean initialize)
Convenience method creating new HRegions.
|
static HRegion |
HRegion.createHRegion(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor hTableDescriptor,
WAL wal,
boolean initialize,
RegionServerServices rsRpcServices)
Convenience method creating new HRegions.
|
private void |
HRegion.doAbortFlushToWAL(WAL wal,
long flushOpSeqId,
Map<byte[],List<org.apache.hadoop.fs.Path>> committedFiles) |
private static void |
HRegion.doSyncOfUnflushedWALChanges(WAL wal,
RegionInfo hri)
Sync unflushed WAL changes.
|
protected long |
HRegion.getNextSequenceId(WAL wal)
Method to safely get the next sequence number.
|
protected HRegion.FlushResultImpl |
HRegion.internalFlushcache(WAL wal,
long myseqid,
Collection<HStore> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker,
FlushLifeCycleTracker tracker)
Flush the memstore.
|
(package private) HRegion.FlushResultImpl |
HRegion.internalFlushCacheAndCommit(WAL wal,
MonitoredTask status,
HRegion.PrepareFlushResult prepareResult,
Collection<HStore> storesToFlush) |
protected HRegion.PrepareFlushResult |
HRegion.internalPrepareFlushCache(WAL wal,
long myseqid,
Collection<HStore> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker,
FlushLifeCycleTracker tracker) |
static HRegion |
HRegion.newHRegion(org.apache.hadoop.fs.Path tableDir,
WAL wal,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration conf,
RegionInfo regionInfo,
TableDescriptor htd,
RegionServerServices rsServices)
A utility method to create new instances of HRegion based on the
HConstants.REGION_IMPL
configuration property. |
static HRegion |
HRegion.openHRegion(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
RegionInfo info,
TableDescriptor htd,
WAL wal)
Open a Region.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
RegionInfo info,
TableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.fs.Path rootDir,
RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf)
Open a Region.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.fs.Path rootDir,
RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf)
Open a Region.
|
static HRegion |
HRegion.openHRegion(RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegionFromTableDir(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir,
RegionInfo info,
TableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static void |
HRegion.warmupHRegion(RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter) |
private boolean |
HRegion.writeFlushRequestMarkerToWAL(WAL wal,
boolean writeFlushWalMarker)
Writes a marker to WAL indicating a flush is requested but cannot be complete due to various
reasons.
|
private void |
HRegion.writeRegionCloseMarker(WAL wal) |
protected void |
HRegion.writeRegionOpenMarker(WAL wal,
long openSeqId) |
Constructor and Description |
---|
HRegion(HRegionFileSystem fs,
WAL wal,
org.apache.hadoop.conf.Configuration confParam,
TableDescriptor htd,
RegionServerServices rsServices)
HRegion constructor.
|
HRegion(org.apache.hadoop.fs.Path tableDir,
WAL wal,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration confParam,
RegionInfo regionInfo,
TableDescriptor htd,
RegionServerServices rsServices)
Deprecated.
Use other constructors.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractFSWAL<W extends WALProvider.WriterBase>
Implementation of
WAL to go against FileSystem ; i.e. |
class |
AsyncFSWAL
An asynchronous implementation of FSWAL.
|
class |
FSHLog
The original implementation of FSWAL.
|
Modifier and Type | Field and Description |
---|---|
private WAL |
WALCoprocessorHost.wal |
private WAL |
WALCoprocessorHost.WALEnvironment.wal |
Modifier and Type | Method and Description |
---|---|
WAL |
WALCoprocessorHost.WALEnvironment.getWAL() |
Modifier and Type | Method and Description |
---|---|
private static WALKeyImpl |
WALUtil.doFullMarkerAppendTransaction(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
WALEdit edit,
MultiVersionConcurrencyControl mvcc,
Map<String,byte[]> extendedAttributes,
boolean sync)
A 'full' WAL transaction involves starting an mvcc transaction followed by an append, an
optional sync, and then a call to complete the mvcc transaction.
|
static WALKeyImpl |
WALUtil.writeBulkLoadMarkerAndSync(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.BulkLoadDescriptor desc,
MultiVersionConcurrencyControl mvcc)
Write a log marker that a bulk load has succeeded and is about to be committed.
|
static WALKeyImpl |
WALUtil.writeCompactionMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.CompactionDescriptor c,
MultiVersionConcurrencyControl mvcc)
Write the marker that a compaction has succeeded and is about to be committed.
|
static WALKeyImpl |
WALUtil.writeFlushMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptor f,
boolean sync,
MultiVersionConcurrencyControl mvcc)
Write a flush marker indicating a start / abort or a complete of a region flush
This write is for internal use only.
|
private static WALKeyImpl |
WALUtil.writeMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
WALEdit edit,
MultiVersionConcurrencyControl mvcc,
Map<String,byte[]> extendedAttributes) |
static WALKeyImpl |
WALUtil.writeRegionEventMarker(WAL wal,
NavigableMap<byte[],Integer> replicationScope,
RegionInfo hri,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.RegionEventDescriptor r,
MultiVersionConcurrencyControl mvcc)
Write a region open marker indicating that the region is opened.
|
Constructor and Description |
---|
WALCoprocessorHost(WAL log,
org.apache.hadoop.conf.Configuration conf)
Constructor
|
WALEnvironment(WALCoprocessor impl,
int priority,
int seq,
org.apache.hadoop.conf.Configuration conf,
WAL wal)
Constructor
|
Modifier and Type | Class and Description |
---|---|
private static class |
DisabledWALProvider.DisabledWAL |
Modifier and Type | Field and Description |
---|---|
(package private) WAL |
DisabledWALProvider.disabled |
private WAL |
AbstractWALRoller.RollController.wal |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<WAL,AbstractWALRoller.RollController> |
AbstractWALRoller.wals |
Modifier and Type | Method and Description |
---|---|
WAL |
WALFactory.getWAL(RegionInfo region) |
WAL |
RegionGroupingProvider.getWAL(RegionInfo region) |
WAL |
WALProvider.getWAL(RegionInfo region) |
WAL |
DisabledWALProvider.getWAL(RegionInfo region) |
private WAL |
RegionGroupingProvider.getWAL(String group) |
Modifier and Type | Method and Description |
---|---|
List<WAL> |
WALFactory.getWALs() |
List<WAL> |
RegionGroupingProvider.getWALs() |
List<WAL> |
WALProvider.getWALs()
Returns the List of WALs that are used by this server
|
List<WAL> |
DisabledWALProvider.getWALs() |
List<WAL> |
AbstractFSWALProvider.getWALs() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractWALRoller.addWAL(WAL wal) |
static long |
AbstractFSWALProvider.extractFileNumFromWAL(WAL wal)
It returns the file create timestamp from the file name.
|
static org.apache.hadoop.fs.Path |
AbstractFSWALProvider.getCurrentFileName(WAL wal)
return the current filename from the current wal.
|
static long |
AbstractFSWALProvider.getLogFileSize(WAL wal)
returns the size of rolled WAL files.
|
static int |
AbstractFSWALProvider.getNumRolledLogFiles(WAL wal)
returns the number of rolled WAL files.
|
(package private) static void |
AbstractFSWALProvider.requestLogRoll(WAL wal)
request a log roll, but don't actually do it.
|
Constructor and Description |
---|
RollController(WAL wal) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.