| Package | Description | 
|---|---|
| org.pentaho.di.trans | 
| Modifier and Type | Method and Description | 
|---|---|
static TransSplitter | 
Trans.executeClustered(TransMeta transMeta,
                TransExecutionConfiguration executionConfiguration)
Execute the transformation in a clustered fashion. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static int | 
Trans.cleanupCluster(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 Result | 
Trans.getClusteredTransformationResult(LogChannelInterface log,
                                TransSplitter transSplitter,
                                Job parentJob)
Gets the clustered transformation result. 
 | 
static Result | 
Trans.getClusteredTransformationResult(LogChannelInterface log,
                                TransSplitter transSplitter,
                                Job parentJob,
                                boolean loggingRemoteWork)
Gets the clustered transformation result. 
 | 
static long | 
Trans.monitorClusteredTransformation(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(LogChannelInterface log,
                              TransSplitter transSplitter,
                              Job parentJob,
                              int sleepTimeSeconds)
Monitors a clustered transformation every second, after all the transformations in a cluster schema are running. 
 | 
Copyright © 2020 Hitachi Vantara. All rights reserved.