Uses of Class
org.pentaho.di.trans.cluster.TransSplitter
-
Uses of TransSplitter in org.pentaho.di.trans
Modifier and TypeMethodDescriptionstatic TransSplitter
Trans.executeClustered
(TransMeta transMeta, TransExecutionConfiguration executionConfiguration) Execute the transformation in a clustered fashion.Modifier and TypeMethodDescriptionstatic 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 final org.pentaho.di.core.Result
Trans.getClusteredTransformationResult
(org.pentaho.di.core.logging.LogChannelInterface log, TransSplitter transSplitter, Job parentJob) Gets the clustered transformation result.static final 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 final 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 final 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.