Package org.pentaho.di.core.logging

Class TransLogTable

java.lang.Object
org.pentaho.di.core.logging.BaseLogTable
org.pentaho.di.core.logging.TransLogTable
All Implemented Interfaces:
Cloneable, org.pentaho.di.core.logging.LogTableCoreInterface, LogTableInterface
public class TransLogTable extends BaseLogTable implements Cloneable, LogTableInterface
This class describes a transformation logging table
Author:
matt

  • Field Details

  • Constructor Details

  • Method Details

    • clone

      public Object clone()
      Specified by:
      clone in interface org.pentaho.di.core.logging.LogTableCoreInterface
      Overrides:
      clone in class BaseLogTable

    • getXML

      public String getXML()
      Specified by:
      getXML in interface LogTableInterface
      Returns:
      The log table meta-data in XML format.

    • loadXML

      public void loadXML(Node node, List<org.pentaho.di.core.database.DatabaseMeta> databases, List<StepMeta> steps)
      Description copied from interface: LogTableInterface
      Load the information for this logging table from the job XML node
      Specified by:
      loadXML in interface LogTableInterface
      Parameters:
      node - the node to load from
      databases - the list of database to reference.
      steps - the steps to reference (or null)

    • saveToRepository

      public void saveToRepository(org.pentaho.di.repository.RepositoryAttributeInterface attributeInterface) throws org.pentaho.di.core.exception.KettleException
      Description copied from class: BaseLogTable
      Save this core information of the log table to the repository using the specified attribute interface.
      Specified by:
      saveToRepository in interface org.pentaho.di.core.logging.LogTableCoreInterface
      Overrides:
      saveToRepository in class BaseLogTable
      Parameters:
      attributeInterface - The attribute interface to use to set attributes
      Throws:
      org.pentaho.di.core.exception.KettleException

    • loadFromRepository

      public void loadFromRepository(org.pentaho.di.repository.RepositoryAttributeInterface attributeInterface) throws org.pentaho.di.core.exception.KettleException
      Specified by:
      loadFromRepository in interface org.pentaho.di.core.logging.LogTableCoreInterface
      Overrides:
      loadFromRepository in class BaseLogTable
      Throws:
      org.pentaho.di.core.exception.KettleException

    • replaceMeta

      public void replaceMeta(org.pentaho.di.core.logging.LogTableCoreInterface logTableInterface)
      Specified by:
      replaceMeta in interface org.pentaho.di.core.logging.LogTableCoreInterface

    • getDefault

      public static TransLogTable getDefault(org.pentaho.di.core.variables.VariableSpace space, HasDatabasesInterface databasesInterface, List<StepMeta> steps)

    • findField

      public org.pentaho.di.core.logging.LogTableField findField(TransLogTable.ID id)

    • getSubject

      public Object getSubject(TransLogTable.ID id)

    • getSubjectString

      public String getSubjectString(TransLogTable.ID id)

    • setBatchIdUsed

      public void setBatchIdUsed(boolean use)

    • isBatchIdUsed

      public boolean isBatchIdUsed()

    • setLogFieldUsed

      public void setLogFieldUsed(boolean use)

    • isLogFieldUsed

      public boolean isLogFieldUsed()

    • getStepnameRead

      public String getStepnameRead()

    • setStepRead

      public void setStepRead(StepMeta read)

    • getStepnameWritten

      public String getStepnameWritten()

    • setStepWritten

      public void setStepWritten(StepMeta written)

    • getStepnameInput

      public String getStepnameInput()

    • setStepInput

      public void setStepInput(StepMeta input)

    • getStepnameOutput

      public String getStepnameOutput()

    • setStepOutput

      public void setStepOutput(StepMeta output)

    • getStepnameUpdated

      public String getStepnameUpdated()

    • setStepUpdate

      public void setStepUpdate(StepMeta update)

    • getStepnameRejected

      public String getStepnameRejected()

    • setStepRejected

      public void setStepRejected(StepMeta rejected)

    • setLogInterval

      public void setLogInterval(String logInterval)
      Sets the logging interval in seconds. Disabled if the logging interval is <=0.
      Parameters:
      logInterval - The log interval value. A value higher than 0 means that the log table is updated every 'logInterval' seconds.

    • getLogInterval

      public String getLogInterval()
      Get the logging interval in seconds. Disabled if the logging interval is <=0. A value higher than 0 means that the log table is updated every 'logInterval' seconds.
      Parameters:
      logInterval - The log interval,

    • getLogSizeLimit

      public String getLogSizeLimit()
      Returns:
      the logSizeLimit

    • setLogSizeLimit

      public void setLogSizeLimit(String logSizeLimit)
      Parameters:
      logSizeLimit - the logSizeLimit to set

    • getLogRecord

      public org.pentaho.di.core.RowMetaAndData getLogRecord(org.pentaho.di.core.logging.LogStatus status, Object subject, Object parent)
      This method calculates all the values that are required
      Specified by:
      getLogRecord in interface org.pentaho.di.core.logging.LogTableCoreInterface
      Parameters:
      id - the id to use or -1 if no id is needed
      status - the log status to use
      subject - the subject to query, in this case a Trans object

    • getLogTableCode

      public String getLogTableCode()
      Specified by:
      getLogTableCode in class BaseLogTable

    • getLogTableType

      public String getLogTableType()
      Specified by:
      getLogTableType in interface org.pentaho.di.core.logging.LogTableCoreInterface

    • getConnectionNameVariable

      public String getConnectionNameVariable()
      Specified by:
      getConnectionNameVariable in interface org.pentaho.di.core.logging.LogTableCoreInterface
      Specified by:
      getConnectionNameVariable in class BaseLogTable

    • getSchemaNameVariable

      public String getSchemaNameVariable()
      Specified by:
      getSchemaNameVariable in interface org.pentaho.di.core.logging.LogTableCoreInterface
      Specified by:
      getSchemaNameVariable in class BaseLogTable

    • getTableNameVariable

      public String getTableNameVariable()
      Specified by:
      getTableNameVariable in interface org.pentaho.di.core.logging.LogTableCoreInterface
      Specified by:
      getTableNameVariable in class BaseLogTable

    • getRecommendedIndexes

      public List<org.pentaho.di.core.row.RowMetaInterface> getRecommendedIndexes()
      Specified by:
      getRecommendedIndexes in interface org.pentaho.di.core.logging.LogTableCoreInterface

    • setAllGlobalParametersToNull

      public void setAllGlobalParametersToNull()
      Overrides:
      setAllGlobalParametersToNull in class BaseLogTable