public class KettleComponent
extends org.pentaho.platform.engine.services.solution.ComponentBase
implements org.pentaho.di.trans.step.RowListener
| Modifier and Type | Field and Description |
|---|---|
static String |
PARAMETER_MAP_CMD_ARG |
static String |
PARAMETER_MAP_PARAMETER |
static String |
PARAMETER_MAP_VARIABLE |
COMPONENT_EXECUTE_FAIL, MISSING_SESSION| Constructor and Description |
|---|
KettleComponent() |
| Modifier and Type | Method and Description |
|---|---|
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() |
createFeedbackParameter, createFeedbackParameter, createNewInstance, execute, getActionDefinition, getActionName, getActionTitle, getComponentDefinition, getComponentDefinition, getId, getInitFailMessage, getInitOk, getInstanceId, getLogId, getObjectName, getProcessId, getResourceAsString, getRuntimeContext, getSession, inputMissingError, outputMissingError, promptNeeded, promptNow, resolveParameter, resourceComponentSettingError, resourceMissingError, setActionDefinition, setActionName, setComponentDefinition, setComponentDefinitionMap, setInstanceId, setProcessId, setRuntimeContext, setSession, validatedebug, debug, error, error, error, fatal, fatal, getMessages, getUserString, info, info, setMessages, trace, trace, warn, warngenLogIdFromInfo, genLogIdFromInfo, genLogIdFromSession, getLoggingLevel, setLoggingLevel, setLogIdequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static final String PARAMETER_MAP_CMD_ARG
public static final String PARAMETER_MAP_VARIABLE
public static final String PARAMETER_MAP_PARAMETER
public org.apache.commons.logging.Log getLogger()
getLogger in class org.pentaho.platform.engine.core.system.PentahoBasepublic boolean init()
init in interface org.pentaho.platform.api.engine.IComponentinit in class org.pentaho.platform.engine.services.solution.ComponentBasepublic boolean validateAction()
validateAction in class org.pentaho.platform.engine.services.solution.ComponentBasepublic boolean executeAction()
executeAction in class org.pentaho.platform.engine.services.solution.ComponentBasepublic void done()
done in interface org.pentaho.platform.api.engine.IComponentdone in class org.pentaho.platform.engine.services.solution.ComponentBasepublic void rowReadEvent(org.pentaho.di.core.row.RowMetaInterface row,
Object[] values)
rowReadEvent in interface org.pentaho.di.trans.step.RowListenerpublic void rowWrittenEvent(org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] row)
throws org.pentaho.di.core.exception.KettleStepException
rowWrittenEvent in interface org.pentaho.di.trans.step.RowListenerorg.pentaho.di.core.exception.KettleStepExceptionpublic void errorRowWrittenEvent(org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] row)
throws org.pentaho.di.core.exception.KettleStepException
errorRowWrittenEvent in interface org.pentaho.di.trans.step.RowListenerorg.pentaho.di.core.exception.KettleStepExceptionpublic 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
org.pentaho.di.core.exception.KettleStepException