class ReplicationSyncUp.DummyServer extends Object implements Server
Modifier and Type | Field and Description |
---|---|
(package private) String |
hostname |
(package private) ZKWatcher |
zkw |
Constructor and Description |
---|
DummyServer(String hostname) |
DummyServer(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) |
ChoreService |
getChoreService()
Returns The
ChoreService instance for this server |
ClusterConnection |
getClusterConnection()
Returns a reference to the servers' cluster connection.
|
org.apache.hadoop.conf.Configuration |
getConfiguration()
Gets the configuration object for this server.
|
ClusterConnection |
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.
|
DummyServer(ZKWatcher zkw)
DummyServer(String hostname)
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 ClusterConnection getConnection()
Server
getConnection
in interface Server
public ChoreService getChoreService()
Server
ChoreService
instance for this servergetChoreService
in interface Server
public ClusterConnection getClusterConnection()
Server
Server.getConnection()
.
Important note: this method returns a reference to Connection which is managed by Server
itself, so callers must NOT attempt to close connection obtained.getClusterConnection
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
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.