private static final class ReplicationSyncUp.DummyServer extends Object implements Server
Modifier and Type | Field and Description |
---|---|
private boolean |
abort |
private org.apache.hadoop.conf.Configuration |
conf |
private String |
hostname |
private ZKWatcher |
zkw |
Constructor and Description |
---|
DummyServer(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zkw) |
Modifier and Type | Method and Description |
---|---|
void |
abort(String why,
Throwable e)
Abort the server or client.
|
Connection |
createConnection(org.apache.hadoop.conf.Configuration conf) |
AsyncClusterConnection |
getAsyncClusterConnection()
Returns a reference to the servers' async cluster connection.
|
ChoreService |
getChoreService()
Returns The
ChoreService instance for this server |
org.apache.hadoop.conf.Configuration |
getConfiguration()
Gets the configuration object for this server.
|
Connection |
getConnection()
Returns a reference to the servers' connection.
|
CoordinatedStateManager |
getCoordinatedStateManager()
Get CoordinatedStateManager instance for this server.
|
org.apache.hadoop.fs.FileSystem |
getFileSystem()
Returns Return the FileSystem object used (can return null!).
|
ServerName |
getServerName()
Returns The unique server name for this server.
|
ZKWatcher |
getZooKeeper()
Gets the ZooKeeper instance for this server.
|
boolean |
isAborted()
Check if the server or client was aborted.
|
boolean |
isStopped()
Returns True if
Stoppable.stop(String) has been closed. |
boolean |
isStopping()
Returns True is the server is Stopping
|
void |
stop(String why)
Stop this service.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAsyncConnection
private final org.apache.hadoop.conf.Configuration conf
private volatile boolean abort
DummyServer(org.apache.hadoop.conf.Configuration conf, ZKWatcher zkw)
public org.apache.hadoop.conf.Configuration getConfiguration()
Server
getConfiguration
in interface Server
public ZKWatcher getZooKeeper()
Server
getZooKeeper
in interface Server
public CoordinatedStateManager getCoordinatedStateManager()
Server
getCoordinatedStateManager
in interface Server
public ServerName getServerName()
Server
getServerName
in interface Server
public void abort(String why, Throwable e)
Abortable
public boolean isAborted()
Abortable
public void stop(String why)
Stoppable
public boolean isStopped()
Stoppable
Stoppable.stop(String)
has been closed.public Connection getConnection()
Server
getConnection
in interface Server
public ChoreService getChoreService()
Server
ChoreService
instance for this servergetChoreService
in interface Server
public org.apache.hadoop.fs.FileSystem getFileSystem()
Server
getFileSystem
in interface Server
public boolean isStopping()
Server
isStopping
in interface Server
public Connection createConnection(org.apache.hadoop.conf.Configuration conf) throws IOException
createConnection
in interface Server
IOException
public AsyncClusterConnection getAsyncClusterConnection()
Server
getAsyncClusterConnection
in interface Server
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.