Uses of Interface
org.apache.hadoop.hbase.wal.WAL
Packages that use WAL
Package
Description
Table of Contents
-
Uses of WAL in org.apache.hadoop.hbase
Methods in org.apache.hadoop.hbase that return WALModifier and TypeMethodDescriptionstatic WALHBaseTestingUtility.createWal(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path rootDir, RegionInfo hri) Deprecated.Create an unmanaged WAL.MockRegionServerServices.getWAL(RegionInfo regionInfo) Methods in org.apache.hadoop.hbase that return types with arguments of type WALMethods in org.apache.hadoop.hbase with parameters of type WALModifier and TypeMethodDescriptionHBaseTestingUtility.createLocalHRegion(RegionInfo info, org.apache.hadoop.conf.Configuration conf, TableDescriptor desc, WAL wal) Deprecated.Create an HRegion that writes to the local tmp dirs with specified walHBaseTestingUtility.createLocalHRegion(TableName tableName, byte[] startKey, byte[] stopKey, org.apache.hadoop.conf.Configuration conf, boolean isReadOnly, Durability durability, WAL wal, byte[]... families) Deprecated.Return a region on which you must callHBaseTestingUtility.closeRegionAndWAL(HRegion)when done.HBaseTestingUtility.createLocalHRegionWithInMemoryFlags(TableName tableName, byte[] startKey, byte[] stopKey, org.apache.hadoop.conf.Configuration conf, boolean isReadOnly, Durability durability, WAL wal, boolean[] compactedMemStore, byte[]... families) Deprecated. -
Uses of WAL in org.apache.hadoop.hbase.coprocessor
Methods in org.apache.hadoop.hbase.coprocessor that return WAL -
Uses of WAL in org.apache.hadoop.hbase.master.region
Methods in org.apache.hadoop.hbase.master.region that return WALModifier and TypeMethodDescriptionprivate static WALMasterRegion.createWAL(WALFactory walFactory, MasterRegionWALRoller walRoller, String serverName, org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walRootDir, RegionInfo regionInfo) -
Uses of WAL in org.apache.hadoop.hbase.regionserver
Fields in org.apache.hadoop.hbase.regionserver declared as WALMethods in org.apache.hadoop.hbase.regionserver that return WALModifier and TypeMethodDescriptionHRegion.getWAL()Returns WAL in use for this regionHRegionServer.getWAL(RegionInfo regionInfo) RegionServerServices.getWAL(RegionInfo regionInfo) Returns the WAL for a particular region.RegionServicesForStores.getWAL()Methods in org.apache.hadoop.hbase.regionserver that return types with arguments of type WALModifier and TypeMethodDescription(package private) Map<WAL,AbstractWALRoller<RegionServerServices>.RollController> LogRoller.getWalNeedsRoll()HRegionServer.getWALs()RegionServerServices.getWALs()Returns the List of WALs that are used by this server Doesn't include the meta WALMethods in org.apache.hadoop.hbase.regionserver with parameters of type WALModifier and TypeMethodDescriptionstatic HRegionHRegion.createHRegion(RegionInfo info, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.conf.Configuration conf, TableDescriptor hTableDescriptor, WAL wal) static HRegionHRegion.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 HRegionHRegion.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 voidHRegion.doAbortFlushToWAL(WAL wal, long flushOpSeqId, Map<byte[], List<org.apache.hadoop.fs.Path>> committedFiles) private static voidHRegion.doSyncOfUnflushedWALChanges(WAL wal, RegionInfo hri) Sync unflushed WAL changes.protected longHRegion.getNextSequenceId(WAL wal) Method to safely get the next sequence number.protected HRegion.FlushResultImplHRegion.internalFlushcache(WAL wal, long myseqid, Collection<HStore> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker, FlushLifeCycleTracker tracker) Flush the memstore.(package private) HRegion.FlushResultImplHRegion.internalFlushCacheAndCommit(WAL wal, MonitoredTask status, HRegion.PrepareFlushResult prepareResult, Collection<HStore> storesToFlush) protected HRegion.PrepareFlushResultHRegion.internalPrepareFlushCache(WAL wal, long myseqid, Collection<HStore> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker, FlushLifeCycleTracker tracker) static HRegionHRegion.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 theHConstants.REGION_IMPLconfiguration property.static HRegionHRegion.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 HRegionHRegion.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 HRegionHRegion.openHRegion(org.apache.hadoop.fs.Path rootDir, RegionInfo info, TableDescriptor htd, WAL wal, org.apache.hadoop.conf.Configuration conf) Open a Region.static HRegionHRegion.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 HRegionHRegion.openHRegion(RegionInfo info, TableDescriptor htd, WAL wal, org.apache.hadoop.conf.Configuration conf) Open a Region.static HRegionHRegion.openHRegion(RegionInfo info, TableDescriptor htd, WAL wal, org.apache.hadoop.conf.Configuration conf, RegionServerServices rsServices, CancelableProgressable reporter) Open a Region.static HRegionHRegion.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 HRegionHRegion.warmupHRegion(RegionInfo info, TableDescriptor htd, WAL wal, org.apache.hadoop.conf.Configuration conf, RegionServerServices rsServices, CancelableProgressable reporter) private booleanHRegion.writeCanNotFlushMarkerToWAL(MultiVersionConcurrencyControl.WriteEntry flushOpSeqIdMVCCEntry, WAL wal, boolean writeFlushWalMarker) This method is only used when we flush but the memstore is empty,if writeFlushWalMarker is true,we write theWALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSHflush marker to WAL when the memstore is empty.private voidHRegion.writeRegionCloseMarker(WAL wal) protected voidHRegion.writeRegionOpenMarker(WAL wal, long openSeqId) Constructors in org.apache.hadoop.hbase.regionserver with parameters of type WALModifierConstructorDescriptionHRegion(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.HRegion(HRegionFileSystem fs, WAL wal, org.apache.hadoop.conf.Configuration confParam, TableDescriptor htd, RegionServerServices rsServices) HRegion constructor. -
Uses of WAL in org.apache.hadoop.hbase.regionserver.wal
Classes in org.apache.hadoop.hbase.regionserver.wal that implement WALModifier and TypeClassDescriptionclassAbstractFSWAL<W extends WALProvider.WriterBase>Implementation ofWALto go againstFileSystem; i.e.classAn asynchronous implementation of FSWAL.classThe original implementation of FSWAL.Fields in org.apache.hadoop.hbase.regionserver.wal declared as WALModifier and TypeFieldDescriptionprivate final WALWALCoprocessorHost.walprivate final WALWALCoprocessorHost.WALEnvironment.walMethods in org.apache.hadoop.hbase.regionserver.wal that return WALMethods in org.apache.hadoop.hbase.regionserver.wal with parameters of type WALModifier and TypeMethodDescriptionprivate static WALKeyImplWALUtil.doFullMarkerAppendTransaction(WAL wal, NavigableMap<byte[], Integer> replicationScope, RegionInfo hri, WALEdit edit, MultiVersionConcurrencyControl mvcc, Map<String, byte[]> extendedAttributes, boolean sync, RegionReplicationSink sink) 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 WALKeyImplWALUtil.writeBulkLoadMarkerAndSync(WAL wal, NavigableMap<byte[], Integer> replicationScope, RegionInfo hri, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.BulkLoadDescriptor desc, MultiVersionConcurrencyControl mvcc, RegionReplicationSink sink) Write a log marker that a bulk load has succeeded and is about to be committed.static WALKeyImplWALUtil.writeCompactionMarker(WAL wal, NavigableMap<byte[], Integer> replicationScope, RegionInfo hri, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.CompactionDescriptor c, MultiVersionConcurrencyControl mvcc, RegionReplicationSink sink) Write the marker that a compaction has succeeded and is about to be committed.static WALKeyImplWALUtil.writeFlushMarker(WAL wal, NavigableMap<byte[], Integer> replicationScope, RegionInfo hri, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptor f, boolean sync, MultiVersionConcurrencyControl mvcc, RegionReplicationSink sink) Write a flush marker indicating a start / abort or a complete of a region flushprivate static WALKeyImplWALUtil.writeMarker(WAL wal, NavigableMap<byte[], Integer> replicationScope, RegionInfo hri, WALEdit edit, MultiVersionConcurrencyControl mvcc, Map<String, byte[]> extendedAttributes, RegionReplicationSink sink) static WALKeyImplWALUtil.writeRegionEventMarker(WAL wal, NavigableMap<byte[], Integer> replicationScope, RegionInfo hri, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.RegionEventDescriptor r, MultiVersionConcurrencyControl mvcc, RegionReplicationSink sink) Write a region open marker indicating that the region is opened.static voidWALUtil.writeReplicationMarkerAndSync(WAL wal, MultiVersionConcurrencyControl mvcc, RegionInfo regionInfo, byte[] rowKey, long timestamp) Constructors in org.apache.hadoop.hbase.regionserver.wal with parameters of type WALModifierConstructorDescriptionWALCoprocessorHost(WAL log, org.apache.hadoop.conf.Configuration conf) ConstructorprivateWALEnvironment(WALCoprocessor impl, int priority, int seq, org.apache.hadoop.conf.Configuration conf, WAL wal) Constructor -
Uses of WAL in org.apache.hadoop.hbase.replication.regionserver
Fields in org.apache.hadoop.hbase.replication.regionserver declared as WAL -
Uses of WAL in org.apache.hadoop.hbase.wal
Classes in org.apache.hadoop.hbase.wal that implement WALFields in org.apache.hadoop.hbase.wal declared as WALModifier and TypeFieldDescription(package private) WALDisabledWALProvider.disabledprivate final WALAbstractWALRoller.RollController.walFields in org.apache.hadoop.hbase.wal with type parameters of type WALModifier and TypeFieldDescriptionprivate final ConcurrentMap<String,Optional<WAL>> AbstractWALProvider.peerId2WALprotected final ConcurrentMap<WAL,AbstractWALRoller<T>.RollController> AbstractWALRoller.walsWALPerformanceEvaluation.walsListenedToMethods in org.apache.hadoop.hbase.wal that return WALModifier and TypeMethodDescriptionprotected WALAbstractFSWALProvider.createRemoteWAL(RegionInfo region, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, String prefix, String suffix) protected abstract WALAbstractWALProvider.createRemoteWAL(RegionInfo region, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, String prefix, String suffix) protected WALAsyncFSWALProvider.createRemoteWAL(RegionInfo region, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, String prefix, String suffix) protected WALFSHLogProvider.createRemoteWAL(RegionInfo region, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, String prefix, String suffix) protected WALRegionGroupingProvider.createRemoteWAL(RegionInfo region, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, String prefix, String suffix) private WALAbstractWALProvider.getRemoteWAL(RegionInfo region, String peerId, String remoteWALDir) final WALAbstractWALProvider.getWAL(RegionInfo region) DisabledWALProvider.getWAL(RegionInfo region) private WALWALFactory.getWAL(RegionInfo region) WALProvider.getWAL(RegionInfo region) protected abstract WALAbstractWALProvider.getWAL0(RegionInfo region) protected WALRegionGroupingProvider.getWAL0(RegionInfo region) Methods in org.apache.hadoop.hbase.wal that return types with arguments of type WALModifier and TypeMethodDescriptionAbstractWALProvider.getWALs()DisabledWALProvider.getWALs()WALFactory.getWALs()WALProvider.getWALs()Returns the List of WALs that are used by this serverAbstractFSWALProvider.getWALs0()AbstractWALProvider.getWALs0()RegionGroupingProvider.getWALs0()Methods in org.apache.hadoop.hbase.wal with parameters of type WALModifier and TypeMethodDescriptionvoidstatic longAbstractFSWALProvider.extractFileNumFromWAL(WAL wal) It returns the file create timestamp (the 'FileNum') from the file name.static org.apache.hadoop.fs.PathAbstractFSWALProvider.getCurrentFileName(WAL wal) return the current filename from the current wal.static longAbstractFSWALProvider.getLogFileSize(WAL wal) returns the size of rolled WAL files.static intAbstractFSWALProvider.getNumRolledLogFiles(WAL wal) returns the number of rolled WAL files.protected final void(package private) static voidAbstractFSWALProvider.requestLogRoll(WAL wal) request a log roll, but don't actually do it.private static voidMethod parameters in org.apache.hadoop.hbase.wal with type arguments of type WALModifier and TypeMethodDescriptionprivate voidAbstractWALProvider.cleanup(IOExceptionConsumer<WAL> cleanupWAL, IOExceptionRunnable finalCleanup) Constructors in org.apache.hadoop.hbase.wal with parameters of type WAL