static int |
Trans.cleanupCluster(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter) |
Cleanup the cluster, including the master and all slaves, and return the number of errors that occurred.
|
static void |
Trans.cleanupSlaveServer(TransSplitter transSplitter,
SlaveServer slaveServer,
TransMeta slaveTransMeta) |
Cleanup the slave server as part of a clustered transformation.
|
static void |
Trans.executeClustered(TransSplitter transSplitter,
TransExecutionConfiguration executionConfiguration) |
Executes an existing TransSplitter, with the transformation already split.
|
static org.pentaho.di.core.Result |
Trans.getClusteredTransformationResult(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter,
Job parentJob) |
Gets the clustered transformation result.
|
static org.pentaho.di.core.Result |
Trans.getClusteredTransformationResult(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter,
Job parentJob,
boolean loggingRemoteWork) |
Gets the clustered transformation result.
|
static long |
Trans.monitorClusteredTransformation(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter,
Job parentJob) |
Monitors a clustered transformation every second, after all the transformations in a cluster schema are running.
|
static long |
Trans.monitorClusteredTransformation(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter,
Job parentJob,
int sleepTimeSeconds) |
Monitors a clustered transformation every second, after all the transformations in a cluster schema are running.
|