Package org.pentaho.platform.plugin.action.kettle

Class KettleComponent

  • All Implemented Interfaces:
    Serializable, org.pentaho.di.trans.step.RowListener, org.pentaho.platform.api.engine.IAuditable, org.pentaho.platform.api.engine.IComponent, org.pentaho.platform.api.engine.ILogger, org.pentaho.platform.api.engine.IParameterResolver
    Direct Known Subclasses:
    Custom1
    public class KettleComponent
extends org.pentaho.platform.engine.services.solution.ComponentBase
implements org.pentaho.di.trans.step.RowListener
    KettleComponent shows a list of available transformations in the root of the choosen repository.
    Author:
    Matt
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static String PARAMETER_MAP_CMD_ARG  
      static String PARAMETER_MAP_PARAMETER  
      static String PARAMETER_MAP_VARIABLE  

      • Fields inherited from class org.pentaho.platform.engine.services.solution.ComponentBase

        COMPONENT_EXECUTE_FAIL, debug, MISSING_SESSION, UNKNOWN_COMPONENT_ID

      • Fields inherited from class org.pentaho.platform.engine.core.system.PentahoBase

        EMPTYLOGID, loggingLevel, LOGID_MASK1, LOGID_MASK2, LOGID_SEPARATOR

      • Fields inherited from interface org.pentaho.platform.api.engine.ILogger

        ACTIVITY_LOG, DEBUG, ERROR, FATAL, INFO, INSTANCE_LOG, SESSION_LOG, SOLUTION_LOG, TRACE, UNKNOWN, WARN

    • Constructor Summary

      Constructors 
      Constructor Description
      KettleComponent()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected boolean customizeTrans​(org.pentaho.di.trans.Trans trans)  
      void done()  
      void errorRowWrittenEvent​(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row)  
      boolean executeAction()
      Execute the specified transformation in the chosen repository.
      org.apache.commons.logging.Log getLogger()  
      boolean init()  
      void processRow​(org.pentaho.commons.connection.memory.MemoryResultSet memResults, org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row)  
      void rowReadEvent​(org.pentaho.di.core.row.RowMetaInterface row, Object[] values)  
      void rowWrittenEvent​(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row)  
      boolean validateAction()  
      protected boolean validateSystemSettings()  

      • Methods inherited from class org.pentaho.platform.engine.services.solution.ComponentBase

        addTempParameter, addTempParameterObject, applyInputsToFormat, audit, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createNewInstance, execute, feedbackAllowed, getActionDefinition, getActionName, getActionTitle, getComponentDefinition, getComponentDefinition, getContentOutputItem, getDefaultOutputStream, getFeedbackOutputStream, getId, getInitFailMessage, getInitOk, getInputBooleanValue, getInputLongValue, getInputNames, getInputParameter, getInputStream, getInputStringValue, getInputStringValue, getInputValue, getInstanceId, getLogId, getObjectName, getOutputContentItem, getOutputContentItem, getOutputItem, getOutputItem, getOutputNames, getOutputPreference, getProcessId, getResource, getResourceAsString, getResourceDataSource, getResourceInputStream, getResourceNames, getRuntimeContext, getSession, getSetting, getSolutionName, getSolutionPath, getStringSetting, inputMissingError, isDefinedInput, isDefinedOutput, isDefinedResource, isPromptPending, outputMissingError, promptNeeded, promptNow, resolveParameter, resourceComponentSettingError, resourceMissingError, saveSetting, setActionDefinition, setActionName, setComponentDefinition, setComponentDefinitionMap, setFeedbackMimeType, setInstanceId, setOutputMimeType, setOutputMimeType, setOutputValue, setProcessId, setRuntimeContext, setSession, validate

      • Methods inherited from class org.pentaho.platform.engine.services.PentahoMessenger

        debug, debug, error, error, error, fatal, fatal, getMessages, getUserString, info, info, setMessages, trace, trace, warn, warn

      • Methods inherited from class org.pentaho.platform.engine.core.system.PentahoBase

        genLogIdFromInfo, genLogIdFromInfo, genLogIdFromSession, getLoggingLevel, setLoggingLevel, setLogId

      • Methods inherited from interface org.pentaho.platform.api.engine.IComponent

        getMessages, setMessages

      • Methods inherited from interface org.pentaho.platform.api.engine.ILogger

        debug, debug, error, error, fatal, fatal, getLoggingLevel, info, info, setLoggingLevel, trace, trace, warn, warn

    • Constructor Detail

      • KettleComponent

        public KettleComponent()

    • Method Detail

      • getLogger

        public org.apache.commons.logging.Log getLogger()
        Specified by:
        getLogger in class org.pentaho.platform.engine.core.system.PentahoBase

      • validateSystemSettings

        protected boolean validateSystemSettings()
        Specified by:
        validateSystemSettings in class org.pentaho.platform.engine.services.solution.ComponentBase

      • init

        public boolean init()
        Specified by:
        init in interface org.pentaho.platform.api.engine.IComponent
        Specified by:
        init in class org.pentaho.platform.engine.services.solution.ComponentBase

      • validateAction

        public boolean validateAction()
        Specified by:
        validateAction in class org.pentaho.platform.engine.services.solution.ComponentBase

      • executeAction

        public boolean executeAction()
        Execute the specified transformation in the chosen repository.
        Specified by:
        executeAction in class org.pentaho.platform.engine.services.solution.ComponentBase

      • customizeTrans

        protected boolean customizeTrans​(org.pentaho.di.trans.Trans trans)

      • done

        public void done()
        Specified by:
        done in interface org.pentaho.platform.api.engine.IComponent
        Specified by:
        done in class org.pentaho.platform.engine.services.solution.ComponentBase

      • rowReadEvent

        public void rowReadEvent​(org.pentaho.di.core.row.RowMetaInterface row,
                         Object[] values)
        Specified by:
        rowReadEvent in interface org.pentaho.di.trans.step.RowListener

      • rowWrittenEvent

        public void rowWrittenEvent​(org.pentaho.di.core.row.RowMetaInterface rowMeta,
                            Object[] row)
                     throws org.pentaho.di.core.exception.KettleStepException
        Specified by:
        rowWrittenEvent in interface org.pentaho.di.trans.step.RowListener
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • errorRowWrittenEvent

        public void errorRowWrittenEvent​(org.pentaho.di.core.row.RowMetaInterface rowMeta,
                                 Object[] row)
                          throws org.pentaho.di.core.exception.KettleStepException
        Specified by:
        errorRowWrittenEvent in interface org.pentaho.di.trans.step.RowListener
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • processRow

        public void processRow​(org.pentaho.commons.connection.memory.MemoryResultSet memResults,
                       org.pentaho.di.core.row.RowMetaInterface rowMeta,
                       Object[] row)
                throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException