Package org.pentaho.di.pan.executors

Class ClusteredTransExecutorService

java.lang.Object
org.pentaho.di.pan.executors.ClusteredTransExecutorService
All Implemented Interfaces:
TransExecutorService
public class ClusteredTransExecutorService extends Object implements TransExecutorService
Service for executing transformations in clustered mode.

  • Constructor Details

    • ClusteredTransExecutorService

      public ClusteredTransExecutorService()
      Default constructor that initializes the service with a new TransSplitterExecutionService instance.

    • ClusteredTransExecutorService

      public ClusteredTransExecutorService(TransSplitterExecutionService transSplitterExecutionService)
      Constructor that allows injecting a custom TransSplitterExecutionService instance.
      Parameters:
      transSplitterExecutionService - the TransSplitterExecutionService to use

  • Method Details

    • execute

      public org.pentaho.di.core.Result execute(org.pentaho.di.core.logging.LogChannelInterface extLog, TransMeta transMeta, Repository repository, TransExecutionConfiguration executionConfiguration, String[] arguments) throws org.pentaho.di.core.exception.KettleException
      Executes a transformation in clustered mode.
      Specified by:
      execute in interface TransExecutorService
      Parameters:
      extLog - the log channel interface for logging
      transMeta - the transformation metadata
      repository - the repository (can be null)
      executionConfiguration - the execution configuration
      arguments - the command-line arguments
      Returns:
      the result of the transformation execution
      Throws:
      org.pentaho.di.core.exception.KettleException - if an error occurs during execution

    • executeClustered

      protected org.pentaho.di.core.Result executeClustered(org.pentaho.di.core.logging.LogChannelInterface extLog, TransMeta transMeta, TransSplitter transSplitter, TransExecutionConfiguration executionConfiguration) throws org.pentaho.di.core.exception.KettleException
      Executes a transformation in clustered mode using the provided TransSplitter and execution configuration.
      Parameters:
      extLog - the log channel interface for logging
      transMeta - the transformation metadata
      transSplitter - the TransSplitter instance for splitting the transformation
      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

    • logClusteredResults

      protected void logClusteredResults(org.pentaho.di.core.logging.LogChannelInterface log, TransMeta transMeta, org.pentaho.di.core.Result result)
      Logs the results of a clustered transformation execution.
      Parameters:
      log - the log channel interface for logging
      transMeta - the transformation metadata
      result - the result of the transformation execution