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

Class KettleComponent

java.lang.Object
org.pentaho.platform.engine.core.system.PentahoBase
org.pentaho.platform.engine.services.PentahoMessenger
org.pentaho.platform.engine.services.solution.ComponentBase
org.pentaho.platform.plugin.action.kettle.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:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    PARAMETER_MAP_CMD_ARG
     
    static final String
    PARAMETER_MAP_PARAMETER
     
    static final 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

    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 class java.lang.Object

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

    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

  • Field Details

  • Constructor Details

    • KettleComponent

      public KettleComponent()

  • Method Details

    • 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