org.apache.nifi.cluster.integration

Class Cluster

java.lang.Object

org.apache.nifi.cluster.integration.Cluster

public class Cluster
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Cluster()
Cluster(long flowElectionTimeout, java.util.concurrent.TimeUnit flowElectionTimeUnit, java.lang.Integer flowElectionMaxNodes)

Method Summary

Modifier and Type	Method and Description
org.apache.curator.framework.CuratorFramework	createCuratorClient()
Node	createNode()
java.util.Set<Node>	getNodes()
java.lang.String	getZooKeeperConnectString()
void	start()
void	stop()
Node	waitForClusterCoordinator(long time, java.util.concurrent.TimeUnit timeUnit)
Node	waitForPrimaryNode(long time, java.util.concurrent.TimeUnit timeUnit)
void	waitUntilAllNodesConnected(long time, java.util.concurrent.TimeUnit timeUnit) Waits for each node in the cluster to connect.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Cluster

public Cluster()
        throws java.io.IOException

Throws:

java.io.IOException

Cluster

public Cluster(long flowElectionTimeout,
               java.util.concurrent.TimeUnit flowElectionTimeUnit,
               java.lang.Integer flowElectionMaxNodes)
        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

start

public void start()

stop

public void stop()

getZooKeeperConnectString

public java.lang.String getZooKeeperConnectString()

getNodes

public java.util.Set<Node> getNodes()

createCuratorClient

public org.apache.curator.framework.CuratorFramework createCuratorClient()

createNode

public Node createNode()

waitForClusterCoordinator

public Node waitForClusterCoordinator(long time,
                                      java.util.concurrent.TimeUnit timeUnit)

waitForPrimaryNode

public Node waitForPrimaryNode(long time,
                               java.util.concurrent.TimeUnit timeUnit)

waitUntilAllNodesConnected

public void waitUntilAllNodesConnected(long time,
                                       java.util.concurrent.TimeUnit timeUnit)

Waits for each node in the cluster to connect. The time given is the maximum amount of time to wait for each node to connect, not for the entire cluster to connect.

Parameters:

time - the max amount of time to wait for a node to connect

timeUnit - the unit of time that the given time value represents