com.datastax.spark.connector.embedded
comma separated host:port pairs, each corresponding to a zk server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002" If the optional chroot suffix is used the example would look like: "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002/app/a" where the client would be rooted at "/app/a" and all paths would be relative to this root - ie getting/setting/etc... "/foo/bar" would result in operations being run on "/app/a/foo/bar" (from the server perspective). Default: the local IP and default port: 2180.
Await until the given condition evaluates to true or the timeout
expires, whichever comes first.
Await until the given condition evaluates to true or the timeout
expires, whichever comes first.
If no timeout is given, take it from the innermost enclosing within
block.
Automatically closes resource after use.
Automatically closes resource after use. Handy for closing streams, files, sessions etc. Similar to try-with-resources in Java 7.
comma separated host:port pairs, each corresponding to a zk server.
comma separated host:port pairs, each corresponding to a zk server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002" If the optional chroot suffix is used the example would look like: "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002/app/a" where the client would be rooted at "/app/a" and all paths would be relative to this root - ie getting/setting/etc... "/foo/bar" would result in operations being run on "/app/a/foo/bar" (from the server perspective). Default: the local IP and default port: 2180.
Copies a text file substituting every occurrence of $ {VARIABLE} with a value from the given map
Copies a text file substituting every occurrence of $ {VARIABLE} with a value from the given map
Makes a new directory or throws an IOException if it cannot be made
Makes a new directory or throws an IOException if it cannot be made
Obtain current time (System.nanoTime) as Duration.
Obtain current time (System.nanoTime) as Duration.
Obtain time remaining for execution of the innermost enclosing within
block or missing that it returns the given duration.
Obtain time remaining for execution of the innermost enclosing within
block or missing that it returns the given duration.
Obtain time remaining for execution of the innermost enclosing within
block or missing that it returns the properly dilated default for this
case from settings (key "akka.
Obtain time remaining for execution of the innermost enclosing within
block or missing that it returns the properly dilated default for this
case from settings (key "akka.test.single-expect-default").
Waits until a port at the given address is open or timeout passes.
Waits until a port at the given address is open or timeout passes.
true if managed to connect to the port, false if timeout happened first
(embeddedZookeeper: StringAdd).self
(embeddedZookeeper: StringFormat).self
(embeddedZookeeper: ArrowAssoc[EmbeddedZookeeper]).x
(Since version 2.10.0) Use leftOfArrow instead
(embeddedZookeeper: Ensuring[EmbeddedZookeeper]).x
(Since version 2.10.0) Use resultOfEnsuring instead
Implements a simple standalone ZooKeeperServer. To create a ZooKeeper client object, the application needs to pass a connection string containing a comma separated list of host:port pairs, each corresponding to a ZooKeeper server.
Session establishment is asynchronous. This constructor will initiate connection to the server and return immediately - potentially (usually) before the session is fully established. The watcher argument specifies the watcher that will be notified of any changes in state. This notification can come at any point before or after the constructor call has returned.
The instantiated ZooKeeper client object will pick an arbitrary server from the connectString and attempt to connect to it. If establishment of the connection fails, another server in the connect string will be tried (the order is non-deterministic, as we random shuffle the list), until a connection is established. The client will continue attempts until the session is explicitly closed.