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, validate
debug, debug, error, error, error, fatal, fatal, getMessages, getUserString, info, info, setMessages, trace, trace, warn, warn
genLogIdFromInfo, genLogIdFromInfo, genLogIdFromSession, getLoggingLevel, setLoggingLevel, setLogId
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public 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.PentahoBase
public boolean init()
init
in interface org.pentaho.platform.api.engine.IComponent
init
in class org.pentaho.platform.engine.services.solution.ComponentBase
public boolean validateAction()
validateAction
in class org.pentaho.platform.engine.services.solution.ComponentBase
public boolean executeAction()
executeAction
in class org.pentaho.platform.engine.services.solution.ComponentBase
public void done()
done
in interface org.pentaho.platform.api.engine.IComponent
done
in class org.pentaho.platform.engine.services.solution.ComponentBase
public void rowReadEvent(org.pentaho.di.core.row.RowMetaInterface row, Object[] values)
rowReadEvent
in interface org.pentaho.di.trans.step.RowListener
public 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.RowListener
org.pentaho.di.core.exception.KettleStepException
public 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.RowListener
org.pentaho.di.core.exception.KettleStepException
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
org.pentaho.di.core.exception.KettleStepException