@InterfaceAudience.Private public abstract class MasterStateStore extends Object
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private MasterRegion |
masterRegion |
private static byte[] |
QUALIFIER |
private byte[] |
stateName |
Modifier | Constructor and Description |
---|---|
protected |
MasterStateStore(MasterRegion masterRegion,
String stateName,
ZKWatcher watcher,
String zkPath) |
Modifier and Type | Method and Description |
---|---|
private Result |
get() |
protected byte[] |
getState() |
private byte[] |
migrate(ZKWatcher watcher,
String zkPath) |
protected void |
setState(byte[] state) |
private void |
tryMigrate(ZKWatcher watcher,
String zkPath) |
private void |
update(byte[] s) |
private static final org.slf4j.Logger LOG
private static final byte[] QUALIFIER
private final MasterRegion masterRegion
private final byte[] stateName
protected MasterStateStore(MasterRegion masterRegion, String stateName, ZKWatcher watcher, String zkPath) throws IOException, org.apache.zookeeper.KeeperException
IOException
org.apache.zookeeper.KeeperException
protected final byte[] getState() throws IOException
IOException
protected final void setState(byte[] state) throws IOException
IOException
private Result get() throws IOException
IOException
private void update(byte[] s) throws IOException
IOException
private byte[] migrate(ZKWatcher watcher, String zkPath) throws org.apache.zookeeper.KeeperException, IOException
org.apache.zookeeper.KeeperException
IOException
private void tryMigrate(ZKWatcher watcher, String zkPath) throws IOException, org.apache.zookeeper.KeeperException
IOException
org.apache.zookeeper.KeeperException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.