@InterfaceAudience.Private public final class ReplicationStorageFactory extends Object
For now we only have zk based implementation.
Modifier | Constructor and Description |
---|---|
private |
ReplicationStorageFactory() |
Modifier and Type | Method and Description |
---|---|
static ReplicationPeerStorage |
getReplicationPeerStorage(ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf)
Create a new
ReplicationPeerStorage . |
static ReplicationQueueStorage |
getReplicationQueueStorage(ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf)
Create a new
ReplicationQueueStorage . |
private ReplicationStorageFactory()
public static ReplicationPeerStorage getReplicationPeerStorage(ZKWatcher zk, org.apache.hadoop.conf.Configuration conf)
ReplicationPeerStorage
.public static ReplicationQueueStorage getReplicationQueueStorage(ZKWatcher zk, org.apache.hadoop.conf.Configuration conf)
ReplicationQueueStorage
.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.