Uses of Class
org.apache.hadoop.hbase.wal.WALFactory
Package
Description
Multi Cluster Replication
-
Uses of WALFactory in org.apache.hadoop.hbase.master.region
Modifier and TypeMethodDescriptionprivate static HRegion
MasterRegion.bootstrap
(org.apache.hadoop.conf.Configuration conf, TableDescriptor td, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walRootDir, WALFactory walFactory, MasterRegionWALRoller walRoller, String serverName, boolean touchInitializingFlag) 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) private static HRegion
MasterRegion.open
(org.apache.hadoop.conf.Configuration conf, TableDescriptor td, RegionInfo regionInfo, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walRootDir, WALFactory walFactory, MasterRegionWALRoller walRoller, String serverName) ModifierConstructorDescriptionprivate
MasterRegion
(Server server, HRegion region, WALFactory walFactory, MasterRegionFlusherAndCompactor flusherAndCompactor, MasterRegionWALRoller walRoller) -
Uses of WALFactory in org.apache.hadoop.hbase.regionserver
Modifier and TypeMethodDescriptionprivate static void
HRegionServer.createNewReplicationInstance
(org.apache.hadoop.conf.Configuration conf, HRegionServer server, org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walDir, org.apache.hadoop.fs.Path oldWALDir, WALFactory walFactory) Load the replication executorService objects, if anyvoid
ReplicationService.initialize
(Server rs, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path logdir, org.apache.hadoop.fs.Path oldLogDir, WALFactory walFactory) Initializes the replication service object.private static <T extends ReplicationService>
THRegionServer.newReplicationInstance
(String classname, Class<T> xface, org.apache.hadoop.conf.Configuration conf, HRegionServer server, org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path logDir, org.apache.hadoop.fs.Path oldLogDir, WALFactory walFactory) (package private) static SplitLogWorker.TaskExecutor.Status
SplitLogWorker.splitLog
(String filename, CancelableProgressable p, org.apache.hadoop.conf.Configuration conf, RegionServerServices server, LastSequenceId sequenceIdChecker, WALFactory factory) Deprecated.Returns Result either DONE, RESIGNED, or ERR.ModifierConstructorDescriptionSplitLogWorker
(org.apache.hadoop.conf.Configuration conf, RegionServerServices server, LastSequenceId sequenceIdChecker, WALFactory factory) Deprecated. -
Uses of WALFactory in org.apache.hadoop.hbase.replication
Modifier and TypeMethodDescriptionvoid
ReplicationSinkServiceImpl.initialize
(Server server, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path logdir, org.apache.hadoop.fs.Path oldLogDir, WALFactory walFactory) -
Uses of WALFactory in org.apache.hadoop.hbase.replication.regionserver
Modifier and TypeMethodDescriptionvoid
Replication.initialize
(Server server, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path logDir, org.apache.hadoop.fs.Path oldLogDir, WALFactory walFactory) ModifierConstructorDescriptionReplicationSourceManager
(ReplicationQueueStorage queueStorage, ReplicationPeers replicationPeers, org.apache.hadoop.conf.Configuration conf, Server server, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path logDir, org.apache.hadoop.fs.Path oldLogDir, UUID clusterId, WALFactory walFactory, SyncReplicationPeerMappingManager syncReplicationPeerMappingManager, MetricsReplicationGlobalSourceSource globalMetrics) Creates a replication manager and sets the watch on all the other registered region servers -
Uses of WALFactory in org.apache.hadoop.hbase.wal
Modifier and TypeFieldDescriptionprotected WALFactory
AbstractWALProvider.factory
private final WALFactory
LazyInitializedWALProvider.factory
private final WALFactory
WALSplitter.walFactory
Modifier and TypeFieldDescriptionprivate static final AtomicReference<WALFactory>
WALFactory.singleton
Modifier and TypeMethodDescriptionstatic WALFactory
WALFactory.getInstance
(org.apache.hadoop.conf.Configuration configuration) (package private) WALFactory
WALSplitter.getWalFactory()
Modifier and TypeMethodDescriptionprotected void
AbstractFSWALProvider.doInit
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId) protected abstract void
AbstractWALProvider.doInit
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId) protected void
RegionGroupingProvider.doInit
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId) final void
AbstractWALProvider.init
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId, Abortable server) void
DisabledWALProvider.init
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId, Abortable abortable) void
WALProvider.init
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId, Abortable server) Set up the provider to create wals.private HRegion
WALPerformanceEvaluation.openRegion
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path dir, TableDescriptor htd, WALFactory wals, long whenToRoll, LogRoller roller) static List<org.apache.hadoop.fs.Path>
WALSplitter.split
(org.apache.hadoop.fs.Path walRootDir, org.apache.hadoop.fs.Path walsDir, org.apache.hadoop.fs.Path archiveDir, org.apache.hadoop.fs.FileSystem walFS, org.apache.hadoop.conf.Configuration conf, WALFactory factory) Split a folder of WAL files.static boolean
WALSplitter.splitLogFile
(org.apache.hadoop.fs.Path walDir, org.apache.hadoop.fs.FileStatus logfile, org.apache.hadoop.fs.FileSystem walFS, org.apache.hadoop.conf.Configuration conf, CancelableProgressable reporter, LastSequenceId idChecker, SplitLogWorkerCoordination splitLogWorkerCoordination, WALFactory factory, RegionServerServices rsServices) Splits a WAL file.private long
WALPerformanceEvaluation.verify
(WALFactory wals, org.apache.hadoop.fs.Path wal, boolean verbose) Verify the content of the WAL file.ModifierConstructorDescription(package private)
LazyInitializedWALProvider
(WALFactory factory, String providerId, String providerConfigName, Abortable abortable) (package private)
WALSplitter
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path walRootDir, org.apache.hadoop.fs.FileSystem walFS, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.FileSystem rootFS) (package private)
WALSplitter
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path walRootDir, org.apache.hadoop.fs.FileSystem walFS, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.FileSystem rootFS, LastSequenceId idChecker, SplitLogWorkerCoordination splitLogWorkerCoordination, RegionServerServices rsServices)