Package org.pentaho.di.pan.executors

Class RemoteTransExecutorService

java.lang.Object
org.pentaho.di.pan.executors.RemoteTransExecutorService
All Implemented Interfaces:
TransExecutorService
public class RemoteTransExecutorService extends Object implements TransExecutorService
Service for executing transformations on a remote server.

  • Constructor Details

    • RemoteTransExecutorService

      public RemoteTransExecutorService()

  • Method Details

    • execute

      public org.pentaho.di.core.Result execute(org.pentaho.di.core.logging.LogChannelInterface log, TransMeta transMeta, Repository repository, TransExecutionConfiguration executionConfiguration, String[] arguments) throws org.pentaho.di.core.exception.KettleException
      Executes a transformation on a remote server.
      Specified by:
      execute in interface TransExecutorService
      Parameters:
      log - 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

    • monitorRemoteTransformation

      protected void monitorRemoteTransformation(org.pentaho.di.core.logging.LogChannelInterface log, TransMeta transMeta, String carteObjectId, SlaveServer remoteSlaveServer)
      Monitors the execution of a remote transformation.
      Parameters:
      log - the log channel interface for logging
      transMeta - the transformation metadata
      carteObjectId - the unique ID of the transformation on the remote server
      remoteSlaveServer - the remote slave server where the transformation is executed