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, debug, MISSING_SESSION, UNKNOWN_COMPONENT_ID
Constructor and Description |
---|
KettleComponent() |
Modifier and Type | Method and 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() |
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
debug, debug, error, error, error, fatal, fatal, getMessages, getUserString, info, info, setMessages, trace, trace, warn, warn
genLogIdFromInfo, genLogIdFromInfo, genLogIdFromSession, getLoggingLevel, setLoggingLevel, setLogId
clone, equals, finalize, 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
protected boolean validateSystemSettings()
validateSystemSettings
in class org.pentaho.platform.engine.services.solution.ComponentBase
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
protected boolean customizeTrans(org.pentaho.di.trans.Trans trans)
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
Copyright © 2021 Hitachi Vantara. All rights reserved.