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
(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, 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
AbstractFSWALProvider.factory
private WALFactory
RegionGroupingProvider.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 TypeMethodDescriptionvoid
AbstractFSWALProvider.init
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId, Abortable abortable) void
DisabledWALProvider.init
(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId, Abortable abortable) void
RegionGroupingProvider.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 abortable) Set up the provider to create wals.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.ModifierConstructorDescription(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)