org.pentaho.di.cluster
Class ClusterGenerator
java.lang.Object
org.pentaho.di.cluster.ClusterGenerator
public class ClusterGenerator
- extends Object
TEST_CLUSTER_NAME
public static final String TEST_CLUSTER_NAME
- See Also:
- Constant Field Values
LOCAL_TEST_SLAVES
public static final SlaveServer[] LOCAL_TEST_SLAVES
- We use one master and 3 slaves
ClusterGenerator
public ClusterGenerator()
throws KettleException
- Throws:
KettleException
launchSlaveServers
public void launchSlaveServers()
throws Exception
- Throws:
Exception
stopSlaveServers
public void stopSlaveServers()
throws Exception
- Throws:
Exception
getClusterSchema
public ClusterSchema getClusterSchema()
- Returns:
- the clusterSchema
setClusterSchema
public void setClusterSchema(ClusterSchema clusterSchema)
- Parameters:
clusterSchema
- the clusterSchema to set