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 © 2018 Hitachi Vantara. All rights reserved.