public class ZooKeeperMesosServices extends Object implements MesosServices
MesosServices
implementation for the ZooKeeper high availability based mode.Constructor and Description |
---|
ZooKeeperMesosServices(ZooKeeperUtilityFactory zooKeeperUtilityFactory) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean cleanup)
Closes all state maintained by the mesos services implementation.
|
MesosWorkerStore |
createMesosWorkerStore(Configuration configuration,
Executor executor)
Creates a
MesosWorkerStore which is used to persist mesos worker in high availability
mode. |
public ZooKeeperMesosServices(ZooKeeperUtilityFactory zooKeeperUtilityFactory)
public MesosWorkerStore createMesosWorkerStore(Configuration configuration, Executor executor) throws Exception
MesosServices
MesosWorkerStore
which is used to persist mesos worker in high availability
mode.createMesosWorkerStore
in interface MesosServices
configuration
- to be usedexecutor
- to run asynchronous tasksException
- if the mesos worker store could not be createdpublic void close(boolean cleanup) throws Exception
MesosServices
close
in interface MesosServices
cleanup
- is true if a cleanup shall be performedException
- if the closing operation failedCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.