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:
- 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
-
-
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 class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Field Detail
-
PARAMETER_MAP_CMD_ARG
public static final String PARAMETER_MAP_CMD_ARG
- See Also:
- Constant Field Values
-
PARAMETER_MAP_VARIABLE
public static final String PARAMETER_MAP_VARIABLE
- See Also:
- Constant Field Values
-
PARAMETER_MAP_PARAMETER
public static final String PARAMETER_MAP_PARAMETER
- See Also:
- Constant Field Values
-
-
Method Detail
-
getLogger
public org.apache.commons.logging.Log getLogger()
- Specified by:
getLogger
in classorg.pentaho.platform.engine.core.system.PentahoBase
-
validateSystemSettings
protected boolean validateSystemSettings()
- Specified by:
validateSystemSettings
in classorg.pentaho.platform.engine.services.solution.ComponentBase
-
init
public boolean init()
- Specified by:
init
in interfaceorg.pentaho.platform.api.engine.IComponent
- Specified by:
init
in classorg.pentaho.platform.engine.services.solution.ComponentBase
-
validateAction
public boolean validateAction()
- Specified by:
validateAction
in classorg.pentaho.platform.engine.services.solution.ComponentBase
-
executeAction
public boolean executeAction()
Execute the specified transformation in the chosen repository.- Specified by:
executeAction
in classorg.pentaho.platform.engine.services.solution.ComponentBase
-
customizeTrans
protected boolean customizeTrans(org.pentaho.di.trans.Trans trans)
-
done
public void done()
- Specified by:
done
in interfaceorg.pentaho.platform.api.engine.IComponent
- Specified by:
done
in classorg.pentaho.platform.engine.services.solution.ComponentBase
-
rowReadEvent
public void rowReadEvent(org.pentaho.di.core.row.RowMetaInterface row, Object[] values)
- Specified by:
rowReadEvent
in interfaceorg.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 interfaceorg.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 interfaceorg.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
-
-