Package org.apache.pinot.tools

Class ClusterStateVerifier

java.lang.Object

org.apache.pinot.tools.PinotZKChanger

org.apache.pinot.tools.ClusterStateVerifier

public class ClusterStateVerifier
extends PinotZKChanger

Field Summary

Fields inherited from class org.apache.pinot.tools.PinotZKChanger

_clusterName, _helixAdmin, _helixManager, _propertyStore

Constructor Summary

Constructors

Constructor	Description
ClusterStateVerifier(String zkAddress, String clusterName)

Method Summary

Modifier and Type	Method	Description
boolean	verifyClusterState(String tableName, long timeoutSec)	Assemble and scan the candidate table names, return true if all the tables are stable.

Methods inherited from class org.apache.pinot.tools.PinotZKChanger

getHelixAdmin, getHelixManager, isStable, printSegmentAssignment, waitForStable

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterStateVerifier

public ClusterStateVerifier(String zkAddress,
                            String clusterName)

Method Detail

verifyClusterState

public boolean verifyClusterState(String tableName,
                                  long timeoutSec)

Assemble and scan the candidate table names, return true if all the tables are stable.

Parameters:

tableName - optional table names which is provided by user and about to scan

timeoutSec - maximum timeout in second

Returns: