public class DwsTableOutput
extends org.pentaho.di.trans.step.BaseStep
| 构造器和说明 |
|---|
DwsTableOutput(org.pentaho.di.trans.step.StepMeta stepMeta,
org.pentaho.di.trans.step.StepDataInterface stepDataInterface,
int copyNr,
org.pentaho.di.trans.TransMeta transMeta,
org.pentaho.di.trans.Trans trans) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
connectToDatabase(DwsTableOutputMeta meta,
DwsTableOutputData data) |
void |
dispose(org.pentaho.di.trans.step.StepMetaInterface smi,
org.pentaho.di.trans.step.StepDataInterface sdi) |
boolean |
init(org.pentaho.di.trans.step.StepMetaInterface smi,
org.pentaho.di.trans.step.StepDataInterface sdi) |
boolean |
processRow(org.pentaho.di.trans.step.StepMetaInterface smi,
org.pentaho.di.trans.step.StepDataInterface sdi) |
addResultFile, addRowListener, addRowSetToInputRowSets, addRowSetToOutputRowSets, addStepListener, batchComplete, buildLog, canProcessOneRow, checkFeedback, cleanup, clearInputRowSets, clearOutputRowSets, closeQuietly, copyVariablesFrom, decrementLinesRead, decrementLinesWritten, dispatch, environmentSubstitute, environmentSubstitute, environmentSubstitute, fieldSubstitute, findInputRowSet, findInputRowSet, findOutputRowSet, findOutputRowSet, getBooleanValueOfVariable, getClusterSize, getContainerObjectId, getCopy, getCurrentInputRowSetNr, getCurrentOutputRowSetNr, getDispatcher, getErrorRowMeta, getErrors, getExtensionDataMap, getFilename, getFirstInputRowSet, getInputRowMeta, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesSkipped, getLinesUpdated, getLinesWritten, getLogChannel, getLogChannelId, getLogFields, getLogLevel, getMetaStore, getNextClassNr, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getObjectType, getOutputRowSets, getParent, getParentVariableSpace, getPartitionID, getPartitionTargets, getPreviewRowMeta, getProcessed, getRegistrationDate, getRemoteInputSteps, getRemoteOutputSteps, getRepartitioning, getRepository, getRepositoryDirectory, getResultFiles, getRow, getRowFrom, getRowHandler, getRowListeners, getRuntime, getServerSockets, getSlaveNr, getSocketRepository, getStatus, getStatusDescription, getStepDataInterface, getStepID, getStepListeners, getStepMeta, getStepMetaInterface, getStepname, getTrans, getTransMeta, getTypeId, getUniqueStepCountAcrossSlaves, getUniqueStepNrAcrossSlaves, getVariable, getVariable, handleGetRowFrom, handlePutRowTo, identifyErrorOutput, incrementLinesInput, incrementLinesOutput, incrementLinesRead, incrementLinesRejected, incrementLinesSkipped, incrementLinesUpdated, incrementLinesWritten, initBeforeStart, initializeVariablesFrom, injectVariables, isBasic, isDebug, isDetailed, isDistributed, isForcingSeparateLogging, isGatheringMetrics, isInitialising, isMapping, isPartitioned, isPaused, isRowLevel, isRunning, isSafeStopped, isStopped, isUsingThreadPriorityManagment, listVariables, logBasic, logBasic, logDebug, logDebug, logDetailed, logDetailed, logError, logError, logError, logMinimal, logMinimal, logRowlevel, logRowlevel, logSummary, markStart, markStop, openRemoteInputStepSocketsOnce, openRemoteOutputStepSocketsOnce, outputIsDone, pauseRunning, putError, putRow, putRowTo, removeRowListener, resumeRunning, rowsetInputSize, rowsetOutputSize, safeModeChecking, safeModeChecking, setCarteObjectId, setCopy, setCurrentInputRowSetNr, setCurrentOutputRowSetNr, setDistributed, setErrorRowMeta, setErrors, setForcingSeparateLogging, setGatheringMetrics, setInputRowMeta, setInputRowSets, setInternalVariables, setLinesInput, setLinesOutput, setLinesRead, setLinesRejected, setLinesSkipped, setLinesUpdated, setLinesWritten, setLogLevel, setMetaStore, setOutputDone, setOutputRowSets, setParentVariableSpace, setPartitioned, setPartitionID, setPartitionTargets, setPaused, setPaused, setPreviewRowMeta, setRepartitioning, setRepository, setRowHandler, setRunning, setSafeStopped, setServerSockets, setSocketRepository, setStepDataInterface, setStepListeners, setStepMeta, setStepMetaInterface, setStepname, setStopped, setTransMeta, setUsingThreadPriorityManagment, setVariable, shareVariablesWith, stopAll, stopRunning, stopRunning, swapFirstInputRowSetIfExists, toString, verifyInputDeadLock, waitUntilTransformationIsStartedpublic DwsTableOutput(org.pentaho.di.trans.step.StepMeta stepMeta,
org.pentaho.di.trans.step.StepDataInterface stepDataInterface,
int copyNr,
org.pentaho.di.trans.TransMeta transMeta,
org.pentaho.di.trans.Trans trans)
public boolean init(org.pentaho.di.trans.step.StepMetaInterface smi,
org.pentaho.di.trans.step.StepDataInterface sdi)
init 在接口中 org.pentaho.di.trans.step.StepInterfaceinit 在类中 org.pentaho.di.trans.step.BaseSteppublic boolean connectToDatabase(DwsTableOutputMeta meta, DwsTableOutputData data) throws org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleDatabaseExceptionpublic boolean processRow(org.pentaho.di.trans.step.StepMetaInterface smi,
org.pentaho.di.trans.step.StepDataInterface sdi)
throws org.pentaho.di.core.exception.KettleException
processRow 在接口中 org.pentaho.di.trans.step.StepInterfaceprocessRow 在类中 org.pentaho.di.trans.step.BaseSteporg.pentaho.di.core.exception.KettleExceptionpublic void dispose(org.pentaho.di.trans.step.StepMetaInterface smi,
org.pentaho.di.trans.step.StepDataInterface sdi)
dispose 在接口中 org.pentaho.di.trans.step.StepInterfacedispose 在类中 org.pentaho.di.trans.step.BaseStepCopyright © 2024. All rights reserved.