Package org.pentaho.di.trans.steps.userdefinedjavaclass

Class TransformClassBase

java.lang.Object
org.pentaho.di.trans.steps.userdefinedjavaclass.TransformClassBase
public abstract class TransformClassBase extends Object

  • Field Details

  • Constructor Details

  • Method Details

    • addResultFile

      public void addResultFile(org.pentaho.di.core.ResultFile resultFile)

    • addRowListener

      public void addRowListener(RowListener rowListener)

    • addStepListener

      public void addStepListener(StepListener stepListener)

    • checkFeedback

      public boolean checkFeedback(long lines)

    • cleanup

      public void cleanup()

    • decrementLinesRead

      public long decrementLinesRead()

    • decrementLinesWritten

      public long decrementLinesWritten()

    • dispose

      public void dispose(StepMetaInterface smi, StepDataInterface sdi)

    • findInputRowSet

      public org.pentaho.di.core.RowSet findInputRowSet(String sourceStep) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • findInputRowSet

      public org.pentaho.di.core.RowSet findInputRowSet(String from, int fromcopy, String to, int tocopy)

    • findOutputRowSet

      public org.pentaho.di.core.RowSet findOutputRowSet(String targetStep) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • findOutputRowSet

      public org.pentaho.di.core.RowSet findOutputRowSet(String from, int fromcopy, String to, int tocopy)

    • getClusterSize

      public int getClusterSize()

    • getCopy

      public int getCopy()

    • getErrorRowMeta

      public org.pentaho.di.core.row.RowMetaInterface getErrorRowMeta()

    • getErrors

      public long getErrors()

    • getInputRowMeta

      public org.pentaho.di.core.row.RowMetaInterface getInputRowMeta()

    • getInputRowSets

      public List<org.pentaho.di.core.RowSet> getInputRowSets()

    • getLinesInput

      public long getLinesInput()

    • getLinesOutput

      public long getLinesOutput()

    • getLinesRead

      public long getLinesRead()

    • getLinesRejected

      public long getLinesRejected()

    • getLinesSkipped

      public long getLinesSkipped()

    • getLinesUpdated

      public long getLinesUpdated()

    • getLinesWritten

      public long getLinesWritten()

    • getOutputRowSets

      public List<org.pentaho.di.core.RowSet> getOutputRowSets()

    • getPartitionID

      public String getPartitionID()

    • getPartitionTargets

      public Map<String,org.pentaho.di.core.BlockingRowSet> getPartitionTargets()

    • getProcessed

      public long getProcessed()

    • getRepartitioning

      public int getRepartitioning()

    • getResultFiles

      public Map<String,org.pentaho.di.core.ResultFile> getResultFiles()

    • getRow

      public Object[] getRow() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getRowFrom

      public Object[] getRowFrom(org.pentaho.di.core.RowSet rowSet) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • getRowListeners

      public List<RowListener> getRowListeners()

    • getRuntime

      public long getRuntime()

    • getSlaveNr

      public int getSlaveNr()

    • getSocketRepository

      public SocketRepository getSocketRepository()

    • getStatus

      public BaseStepData.StepExecutionStatus getStatus()

    • getStatusDescription

      public String getStatusDescription()

    • getStepDataInterface

      public StepDataInterface getStepDataInterface()

    • getStepID

      public String getStepID()

    • getStepListeners

      public List<StepListener> getStepListeners()

    • getStepMeta

      public StepMeta getStepMeta()

    • getStepname

      public String getStepname()

    • getTrans

      public Trans getTrans()

    • getTransMeta

      public TransMeta getTransMeta()

    • getTypeId

      public String getTypeId()

    • getUniqueStepCountAcrossSlaves

      public int getUniqueStepCountAcrossSlaves()

    • getUniqueStepNrAcrossSlaves

      public int getUniqueStepNrAcrossSlaves()

    • getVariable

      public String getVariable(String variableName)

    • getVariable

      public String getVariable(String variableName, String defaultValue)

    • incrementLinesInput

      public long incrementLinesInput()

    • incrementLinesOutput

      public long incrementLinesOutput()

    • incrementLinesRead

      public long incrementLinesRead()

    • incrementLinesRejected

      public long incrementLinesRejected()

    • incrementLinesSkipped

      public long incrementLinesSkipped()

    • incrementLinesUpdated

      public long incrementLinesUpdated()

    • incrementLinesWritten

      public long incrementLinesWritten()

    • init

      public boolean init(StepMetaInterface stepMetaInterface, StepDataInterface stepDataInterface)

    • initBeforeStart

      public void initBeforeStart() throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • isDistributed

      public boolean isDistributed()

    • isInitialising

      public boolean isInitialising()

    • isPartitioned

      public boolean isPartitioned()

    • isSafeModeEnabled

      public boolean isSafeModeEnabled()

    • isStopped

      public boolean isStopped()

    • isUsingThreadPriorityManagment

      public boolean isUsingThreadPriorityManagment()

    • logBasic

      public void logBasic(String s)

    • logDebug

      public void logDebug(String s)

    • logDetailed

      public void logDetailed(String s)

    • logError

      public void logError(String s)

    • logError

      public void logError(String s, Throwable e)

    • logMinimal

      public void logMinimal(String s)

    • logRowlevel

      public void logRowlevel(String s)

    • logSummary

      public void logSummary()

    • markStart

      public void markStart()

    • markStop

      public void markStop()

    • openRemoteInputStepSocketsOnce

      public void openRemoteInputStepSocketsOnce() throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • openRemoteOutputStepSocketsOnce

      public void openRemoteOutputStepSocketsOnce() throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • outputIsDone

      public boolean outputIsDone()

    • processRow

      public abstract boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • putError

      public void putError(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row, long nrErrors, String errorDescriptions, String fieldNames, String errorCodes) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • putRow

      public void putRow(org.pentaho.di.core.row.RowMetaInterface row, Object[] data) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • putRowTo

      public void putRowTo(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row, org.pentaho.di.core.RowSet rowSet) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • removeRowListener

      public void removeRowListener(RowListener rowListener)

    • rowsetInputSize

      public int rowsetInputSize()

    • rowsetOutputSize

      public int rowsetOutputSize()

    • safeModeChecking

      public void safeModeChecking(org.pentaho.di.core.row.RowMetaInterface row) throws org.pentaho.di.core.exception.KettleRowException
      Throws:
      org.pentaho.di.core.exception.KettleRowException

    • setErrors

      public void setErrors(long errors)

    • setInputRowMeta

      public void setInputRowMeta(org.pentaho.di.core.row.RowMetaInterface rowMeta)

    • setInputRowSets

      public void setInputRowSets(List<org.pentaho.di.core.RowSet> inputRowSets)

    • setLinesInput

      public void setLinesInput(long newLinesInputValue)

    • setLinesOutput

      public void setLinesOutput(long newLinesOutputValue)

    • setLinesRead

      public void setLinesRead(long newLinesReadValue)

    • setLinesRejected

      public void setLinesRejected(long linesRejected)

    • setLinesSkipped

      public void setLinesSkipped(long newLinesSkippedValue)

    • setLinesUpdated

      public void setLinesUpdated(long newLinesUpdatedValue)

    • setLinesWritten

      public void setLinesWritten(long newLinesWrittenValue)

    • setOutputDone

      public void setOutputDone()

    • setOutputRowSets

      public void setOutputRowSets(List<org.pentaho.di.core.RowSet> outputRowSets)

    • setStepListeners

      public void setStepListeners(List<StepListener> stepListeners)

    • setVariable

      public void setVariable(String variableName, String variableValue)

    • stopAll

      public void stopAll()

    • stopRunning

      public void stopRunning(StepMetaInterface stepMetaInterface, StepDataInterface stepDataInterface) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • getInfoSteps

      public static String[] getInfoSteps()

    • getFields

      public static void getFields(boolean clearResultFields, org.pentaho.di.core.row.RowMetaInterface row, String originStepname, org.pentaho.di.core.row.RowMetaInterface[] info, StepMeta nextStep, org.pentaho.di.core.variables.VariableSpace space, List<?> fields) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • getStepIOMeta

      public static StepIOMetaInterface getStepIOMeta(UserDefinedJavaClassMeta meta)

    • getParameter

      public String getParameter(String tag)

    • findInfoRowSet

      public org.pentaho.di.core.RowSet findInfoRowSet(String tag) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • findTargetRowSet

      public org.pentaho.di.core.RowSet findTargetRowSet(String tag) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • get

      public FieldHelper get(TransformClassBase.Fields type, String name) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException

    • createOutputRow

      public Object[] createOutputRow(Object[] inputRow, int outputRowSize)