Package 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	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	Description
PinotZKChanger(String zkAddress, String clusterName)

Method Summary

Modifier and Type	Method	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()