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) |
AsyncClusterConnection |
getAsyncClusterConnection()
Returns a reference to the servers' async cluster connection.
|
ChoreService |
getChoreService() |
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() |
ServerName |
getServerName() |
ZKWatcher |
getZooKeeper()
Gets the ZooKeeper instance for this server.
|
boolean |
isAborted()
Check if the server or client was aborted.
|
boolean |
isStopped() |
boolean |
isStopping() |
void |
stop(String why)
Stop this service.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAsyncConnection
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()
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()
isStopped
in interface Stoppable
Stoppable.stop(String)
has been closed.public Connection getConnection()
Server
getConnection
in interface Server
public ChoreService getChoreService()
getChoreService
in interface Server
ChoreService
instance for this serverpublic org.apache.hadoop.fs.FileSystem getFileSystem()
getFileSystem
in interface Server
public boolean isStopping()
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.