Package org.pentaho.di.pan.executors

Class TransSplitterExecutionService

java.lang.Object

org.pentaho.di.pan.executors.TransSplitterExecutionService

public class TransSplitterExecutionService
extends Object

Constructor Summary

Constructors

Constructor	Description
TransSplitterExecutionService()

Method Summary

Modifier and Type	Method	Description
protected void	cleanupClusterAfterError(org.pentaho.di.core.logging.LogChannelInterface extLog, TransSplitter transSplitter, Exception e)	Cleans up the cluster in case of an error during execution.
org.pentaho.di.core.Result	executeClustered(org.pentaho.di.core.logging.LogChannelInterface extLog, TransSplitter transSplitter, Job parentJob, TransExecutionConfiguration executionConfiguration)	Executes a transformation in clustered mode.
protected void	executeClustered(org.pentaho.di.core.logging.LogChannelInterface extLog, TransSplitter transSplitter, TransExecutionConfiguration executionConfiguration)	Executes a clustered transformation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TransSplitterExecutionService

public TransSplitterExecutionService()

Method Details

executeClustered

public org.pentaho.di.core.Result executeClustered(org.pentaho.di.core.logging.LogChannelInterface extLog,
 TransSplitter transSplitter,
 Job parentJob,
 TransExecutionConfiguration executionConfiguration)
                                            throws org.pentaho.di.core.exception.KettleException

Executes a transformation in clustered mode.

Parameters:

extLog - the log channel interface for logging

transSplitter - the TransSplitter instance for splitting the transformation

parentJob - the parent job (can be null)

executionConfiguration - the execution configuration

Returns:

the result of the clustered transformation execution

Throws:

org.pentaho.di.core.exception.KettleException - if an error occurs during execution

executeClustered

protected void executeClustered(org.pentaho.di.core.logging.LogChannelInterface extLog,
 TransSplitter transSplitter,
 TransExecutionConfiguration executionConfiguration)
                         throws org.pentaho.di.core.exception.KettleException

Executes a clustered transformation.

Parameters:

extLog - the log channel interface for logging

transSplitter - the TransSplitter instance for splitting the transformation

executionConfiguration - the execution configuration

Throws:

org.pentaho.di.core.exception.KettleException - if an error occurs during execution

cleanupClusterAfterError

protected void cleanupClusterAfterError(org.pentaho.di.core.logging.LogChannelInterface extLog,
 TransSplitter transSplitter,
 Exception e)
                                 throws org.pentaho.di.core.exception.KettleException

Cleans up the cluster in case of an error during execution.

Parameters:

extLog - the log channel interface for logging

transSplitter - the TransSplitter instance for splitting the transformation

e - the exception that occurred during execution

Throws:

org.pentaho.di.core.exception.KettleException - if an error occurs during cleanup