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

Class TransformClassBase

  • public abstract class TransformClassBase
extends Object

    • Method Detail

      • 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()

      • 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

      • getRuntime

        public long getRuntime()

      • getSlaveNr

        public int getSlaveNr()

      • getStatusDescription

        public String getStatusDescription()

      • getStepID

        public String getStepID()

      • 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)

      • 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()

      • 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)

      • 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

      • 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

      • 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

      • createOutputRow

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