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()
ServergetConfiguration in interface Serverpublic ZKWatcher getZooKeeper()
ServergetZooKeeper in interface Serverpublic CoordinatedStateManager getCoordinatedStateManager()
ServergetCoordinatedStateManager in interface Serverpublic ServerName getServerName()
ServergetServerName in interface Serverpublic void abort(String why, Throwable e)
Abortablepublic boolean isAborted()
Abortablepublic void stop(String why)
Stoppablepublic boolean isStopped()
StoppableStoppable.stop(String) has been closed.public ClusterConnection getConnection()
ServergetConnection in interface Serverpublic ChoreService getChoreService()
ServerChoreService instance for this servergetChoreService in interface Serverpublic ClusterConnection getClusterConnection()
ServerServer.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 Serverpublic org.apache.hadoop.fs.FileSystem getFileSystem()
ServergetFileSystem in interface Serverpublic boolean isStopping()
ServerisStopping in interface Serverpublic Connection createConnection(org.apache.hadoop.conf.Configuration conf) throws IOException
createConnection in interface ServerIOExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.