org.pentaho.di.cluster
Class ClusterGenerator

java.lang.Object
  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