org.pentaho.di.cluster
Class ClusterGenerator

java.lang.Object
  extended by org.pentaho.di.cluster.ClusterGenerator

public class ClusterGenerator
extends Object


Field Summary
static SlaveServer[] LOCAL_TEST_SLAVES
          We use one master and 3 slaves
static String TEST_CLUSTER_NAME
           
 
Constructor Summary
ClusterGenerator()
           
 
Method Summary
 ClusterSchema getClusterSchema()
           
 void launchSlaveServers()
           
 void setClusterSchema(ClusterSchema clusterSchema)
           
 void stopSlaveServers()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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

Constructor Detail

ClusterGenerator

public ClusterGenerator()
                 throws KettleException
Throws:
KettleException
Method Detail

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