Package org.pentaho.di.trans.ael.websocket

Class TransWebSocketEngineAdapter

  • All Implemented Interfaces:
    ExecutorInterface, org.pentaho.di.core.ExtensionDataInterface, HasLogChannelInterface, org.pentaho.di.core.logging.LoggingObjectInterface, org.pentaho.di.core.logging.LoggingObjectLifecycleInterface, org.pentaho.di.core.parameters.NamedParams, org.pentaho.di.core.variables.VariableSpace
    public class TransWebSocketEngineAdapter
extends Trans
    Created by fcamara on 8/17/17.

    • Constructor Detail

      • TransWebSocketEngineAdapter

        public TransWebSocketEngineAdapter​(TransMeta transMeta,
                                   String host,
                                   int port,
                                   boolean ssl)

    • Method Detail

      • getDaemonEndpoint

        public DaemonMessagesClientEndpoint getDaemonEndpoint()
                                               throws org.pentaho.di.core.exception.KettleException
        Throws:
        org.pentaho.di.core.exception.KettleException

      • setLogLevel

        public void setLogLevel​(org.pentaho.di.core.logging.LogLevel logLogLevel)
        Description copied from class: Trans
        Sets the log level.
        Overrides:
        setLogLevel in class Trans
        Parameters:
        logLogLevel - the new log level

      • killAll

        public void killAll()
        Description copied from class: Trans
        Attempts to stops all running steps and subtransformations. If all steps have finished, the transformation is marked as Finished.
        Overrides:
        killAll in class Trans

      • stopAll

        public void stopAll()
        Description copied from class: Trans
        Stops all steps from running, and alerts any registered listeners.
        Overrides:
        stopAll in class Trans

      • safeStop

        public void safeStop()
        Description copied from class: Trans
        Stops only input steps so that all downstream steps can finish processing rows that have already been input
        Overrides:
        safeStop in class Trans

      • prepareExecution

        public void prepareExecution​(String[] arguments)
                      throws org.pentaho.di.core.exception.KettleException
        Description copied from class: Trans
        Prepares the transformation for execution. This includes setting the arguments and parameters as well as preparing and tracking the steps and hops in the transformation.
        Overrides:
        prepareExecution in class Trans
        Parameters:
        arguments - the arguments to use for this transformation
        Throws:
        org.pentaho.di.core.exception.KettleException - in case the transformation could not be prepared (initialized)

      • startThreads

        public void startThreads()
                  throws org.pentaho.di.core.exception.KettleException
        Description copied from class: Trans
        Starts the threads prepared by prepareThreads(). Before you start the threads, you can add RowListeners to them.
        Overrides:
        startThreads in class Trans
        Throws:
        org.pentaho.di.core.exception.KettleException - if there is a communication error with a remote output socket.

      • closeSessionMonitor

        public void closeSessionMonitor()

      • waitUntilFinished

        public void waitUntilFinished()
        Description copied from class: Trans
        Waits until all RunThreads have finished.
        Overrides:
        waitUntilFinished in class Trans

      • getErrors

        public int getErrors()
        Description copied from class: Trans
        Gets the number of errors that have occurred during execution of the transformation.
        Overrides:
        getErrors in class Trans
        Returns:
        the number of errors

      • getResult

        public org.pentaho.di.core.Result getResult()
        Description copied from class: Trans
        Gets the result of the transformation. The Result object contains such measures as the number of errors, number of lines read/written/input/output/updated/rejected, etc.
        Overrides:
        getResult in class Trans
        Returns:
        the Result object containing resulting measures from execution of the transformation

      • finishProcess

        public void finishProcess​(boolean emitToAllSteps)

      • addRowProducer

        public RowProducer addRowProducer​(String stepname,
                                  int copynr)
                           throws org.pentaho.di.core.exception.KettleException
        Description copied from class: Trans
        This adds a row producer to the transformation that just got set up. It is preferable to run this BEFORE execute() but after prepareExecution()
        Overrides:
        addRowProducer in class Trans
        Parameters:
        stepname - The step to produce rows for
        copynr - The copynr of the step to produce row for (normally 0 unless you have multiple copies running)
        Returns:
        the row producer
        Throws:
        org.pentaho.di.core.exception.KettleException - in case the thread/step to produce rows for could not be found.
        See Also:
        Trans.execute(String[]), Trans.prepareExecution(String[])