org.apache.pinot.tools

Class PinotZKChanger

java.lang.Object

org.apache.pinot.tools.PinotZKChanger

Direct Known Subclasses:

ClusterStateVerifier, PinotIdealstateChanger, PinotNumReplicaChanger, PinotTableRebalancer

public class PinotZKChanger
extends Object

This class provides utilities that change zookeeper state in a cluster

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clusterName
protected org.apache.helix.manager.zk.ZKHelixAdmin	helixAdmin
protected org.apache.helix.HelixManager	helixManager
protected org.apache.helix.store.zk.ZkHelixPropertyStore<org.apache.helix.ZNRecord>	propertyStore

Constructor Summary

Constructors

Constructor and Description
PinotZKChanger(String zkAddress, String clusterName)

Method Summary

Modifier and Type	Method and Description
org.apache.helix.manager.zk.ZKHelixAdmin	getHelixAdmin()
org.apache.helix.HelixManager	getHelixManager()
int	isStable(String tableName) return true if IdealState = ExternalView
protected void	printSegmentAssignment(Map<String,Map<String,String>> mapping)
void	waitForStable(String resourceName) Wait till state has stabilized isStable(String)

Methods inherited from class java.lang.Object

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

Field Detail

helixAdmin

protected org.apache.helix.manager.zk.ZKHelixAdmin helixAdmin

helixManager

protected org.apache.helix.HelixManager helixManager

clusterName

protected String clusterName

propertyStore

protected org.apache.helix.store.zk.ZkHelixPropertyStore<org.apache.helix.ZNRecord> propertyStore

Constructor Detail

PinotZKChanger

public PinotZKChanger(String zkAddress,
                      String clusterName)

Method Detail

getHelixAdmin

public org.apache.helix.manager.zk.ZKHelixAdmin getHelixAdmin()

isStable

public int isStable(String tableName)

return true if IdealState = ExternalView

Returns:

waitForStable

public void waitForStable(String resourceName)
                   throws InterruptedException

Wait till state has stabilized isStable(String)

Parameters:

resourceName -

Throws:

InterruptedException

printSegmentAssignment

protected void printSegmentAssignment(Map<String,Map<String,String>> mapping)
                               throws Exception

Throws:

Exception

getHelixManager

public org.apache.helix.HelixManager getHelixManager()