org.pentaho.di.trans.steps.terafast

Class TeraFastMeta

java.lang.Object

org.pentaho.di.trans.step.BaseStepMeta

org.pentaho.di.core.util.AbstractStepMeta

org.pentaho.di.trans.steps.terafast.TeraFastMeta

All Implemented Interfaces:

Cloneable, StepAttributesInterface, StepMetaInterface

public class TeraFastMeta
extends AbstractStepMeta

Author:

Michael Gugerell(asc145)

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_DATA_FILE Default data file.
static int	DEFAULT_ERROR_LIMIT Default error limit.
static String	DEFAULT_FASTLOAD_PATH Default fast load path.
static int	DEFAULT_SESSIONS Default session.
static String	DEFAULT_TARGET_TABLE
static boolean	DEFAULT_TRUNCATETABLE
static boolean	DEFAULT_VARIABLE_SUBSTITUTION
static PluginMessages	MESSAGES

Fields inherited from class org.pentaho.di.trans.step.BaseStepMeta

loggingObject, STEP_ATTRIBUTES_FILE

Constructor Summary

Constructors

Constructor and Description
TeraFastMeta()

Method Summary

Modifier and Type	Method and Description
void	check(List<org.pentaho.di.core.CheckResultInterface> remarks, TransMeta transmeta, StepMeta stepMeta, org.pentaho.di.core.row.RowMetaInterface prev, String[] input, String[] output, org.pentaho.di.core.row.RowMetaInterface info, org.pentaho.di.core.variables.VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) Checks the settings of this step and puts the findings in a remarks List.
Object	clone() Make an exact copy of this step, make sure to explicitly copy Collections etc.
org.pentaho.di.core.database.Database	connectToDatabase()
StringPluginProperty	getControlFile()
StringPluginProperty	getDataFile()
IntegerPluginProperty	getErrorLimit()
StringPluginProperty	getFastloadPath()
void	getFields(org.pentaho.di.core.row.RowMetaInterface inputRowMeta, String name, org.pentaho.di.core.row.RowMetaInterface[] info, StepMeta nextStep, org.pentaho.di.core.variables.VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) Gets the fields.
StringPluginProperty	getLogFile()
String	getQuotedSchemaTableName(org.pentaho.di.core.variables.VariableSpace space)
org.pentaho.di.core.row.RowMetaInterface	getRequiredFields(org.pentaho.di.core.variables.VariableSpace space) The natural way of data flow in a transformation is source-to-target.
IntegerPluginProperty	getSessions()
StepInterface	getStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta, Trans disp) Get the executing step, needed by Trans to launch a step.
StepDataInterface	getStepData() Get a new instance of the appropriate data class.
StringListPluginProperty	getStreamFieldList()
StringListPluginProperty	getTableFieldList()
StringPluginProperty	getTargetTable()
BooleanPluginProperty	getTruncateTable()
BooleanPluginProperty	getUseControlFile()
BooleanPluginProperty	getVariableSubstitution()
void	setControlFile(StringPluginProperty controlFile)
void	setDataFile(StringPluginProperty dataFile)
void	setDefault() Set default values
void	setErrorLimit(IntegerPluginProperty errorLimit)
void	setFastloadPath(StringPluginProperty fastloadPath)
void	setLogFile(StringPluginProperty logFile)
void	setSessions(IntegerPluginProperty sessions)
void	setStreamFieldList(StringListPluginProperty streamFieldList)
void	setTableFieldList(StringListPluginProperty tableFieldList)
void	setTargetTable(StringPluginProperty targetTable)
void	setTruncateTable(BooleanPluginProperty truncateTable)
void	setUseControlFile(BooleanPluginProperty useControlFile)
void	setVariableSubstitution(BooleanPluginProperty variableSubstitution)

Methods inherited from class org.pentaho.di.core.util.AbstractStepMeta

getConnectionName, getDbMeta, getProperties, getPropertyFactory, getXML, loadXML, readFromPreferences, readRep, saveAsPreferences, saveRep, setConnectionName, setDbMeta

Methods inherited from class org.pentaho.di.trans.step.BaseStepMeta

analyseImpact, analyseImpact, cancelQueries, check, check, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, extractStepMetadataEntries, findAttribute, findParent, getActiveReferencedObjectDescription, getDescription, getDialogClassName, getFields, getLog, getLogChannelId, getName, getObjectCopy, getObjectId, getObjectRevision, getObjectType, getOptionalStreams, getParent, getParentStepMeta, getReferencedObjectDescriptions, getRepCode, getRepositoryDirectory, getRequiredFields, getResourceDependencies, getSQLStatements, getSQLStatements, getStepInjectionMetadataEntries, getStepIOMeta, getStepMetaInjectionInterface, getSupportedTransformationTypes, getTableFields, getTooltip, getUsedArguments, getUsedDatabaseConnections, getUsedLibraries, getXmlCode, handleStreamSelection, hasChanged, hasRepositoryReferences, isBasic, isDebug, isDetailed, isReferencedObjectEnabled, isRowLevel, loadReferencedObject, loadReferencedObject, loadXML, loadXML, logBasic, logBasic, logDebug, logDebug, logDetailed, logDetailed, logError, logError, logError, logMinimal, logMinimal, logRowlevel, logRowlevel, lookupRepositoryReferences, readRep, readRep, resetStepIoMeta, saveRep, searchInfoAndTargetSteps, setChanged, setChanged, setParentStepMeta, supportsErrorHandling

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.pentaho.di.trans.step.StepMetaInterface

analyseImpact, analyseImpact, cancelQueries, check, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, extractStepMetadataEntries, getActiveReferencedObjectDescription, getDialogClassName, getFields, getOptionalStreams, getParentStepMeta, getReferencedObjectDescriptions, getResourceDependencies, getSQLStatements, getSQLStatements, getStepIOMeta, getStepMetaInjectionInterface, getSupportedTransformationTypes, getTableFields, getUsedArguments, getUsedDatabaseConnections, getUsedLibraries, handleStreamSelection, hasChanged, hasRepositoryReferences, isReferencedObjectEnabled, loadReferencedObject, loadXML, lookupRepositoryReferences, readRep, resetStepIoMeta, saveRep, searchInfoAndTargetSteps, setChanged, setParentStepMeta, supportsErrorHandling

Field Detail

MESSAGES

public static final PluginMessages MESSAGES

DEFAULT_FASTLOAD_PATH

public static final String DEFAULT_FASTLOAD_PATH

Default fast load path.

See Also:

Constant Field Values

DEFAULT_DATA_FILE

public static final String DEFAULT_DATA_FILE

Default data file.

See Also:

Constant Field Values

DEFAULT_TARGET_TABLE

public static final String DEFAULT_TARGET_TABLE

See Also:

Constant Field Values

DEFAULT_SESSIONS

public static final int DEFAULT_SESSIONS

Default session.

See Also:

Constant Field Values

DEFAULT_TRUNCATETABLE

public static final boolean DEFAULT_TRUNCATETABLE

See Also:

Constant Field Values

DEFAULT_VARIABLE_SUBSTITUTION

public static final boolean DEFAULT_VARIABLE_SUBSTITUTION

See Also:

Constant Field Values

DEFAULT_ERROR_LIMIT

public static final int DEFAULT_ERROR_LIMIT

Default error limit.

See Also:

Constant Field Values

Constructor Detail

TeraFastMeta

public TeraFastMeta()

Method Detail

check

public void check(List<org.pentaho.di.core.CheckResultInterface> remarks,
                  TransMeta transmeta,
                  StepMeta stepMeta,
                  org.pentaho.di.core.row.RowMetaInterface prev,
                  String[] input,
                  String[] output,
                  org.pentaho.di.core.row.RowMetaInterface info,
                  org.pentaho.di.core.variables.VariableSpace space,
                  Repository repository,
                  org.pentaho.metastore.api.IMetaStore metaStore)

Checks the settings of this step and puts the findings in a remarks List.

Specified by:

check in interface StepMetaInterface

Overrides:

check in class BaseStepMeta

Parameters:

remarks - The list to put the remarks in @see org.pentaho.di.core.CheckResult

stepMeta - The stepMeta to help checking

prev - The fields coming from the previous step

input - The input step names

output - The output step names

info - The fields that are used as information by the step

space - the variable space to resolve variable expressions with

repository - the repository to use to load Kettle metadata objects impacting the output fields

metaStore - the MetaStore to use to load additional external data or metadata impacting the output fields

See Also:

StepMetaInterface.check(java.util.List, org.pentaho.di.trans.TransMeta, org.pentaho.di.trans.step.StepMeta, org.pentaho.di.core.row.RowMetaInterface, java.lang.String[], java.lang.String[], org.pentaho.di.core.row.RowMetaInterface)

getQuotedSchemaTableName

public String getQuotedSchemaTableName(org.pentaho.di.core.variables.VariableSpace space)
                                throws org.pentaho.di.core.exception.KettleException

Parameters:

space - the variableSpace to be used.

Returns:

the quoted and resolved schema table name.

Throws:

org.pentaho.di.core.exception.KettleException - if no table specified.

connectToDatabase

public org.pentaho.di.core.database.Database connectToDatabase()
                                                        throws org.pentaho.di.core.exception.KettleException

Returns:

the database.

Throws:

org.pentaho.di.core.exception.KettleException - if an error occurs.

getStep

public StepInterface getStep(StepMeta stepMeta,
                             StepDataInterface stepDataInterface,
                             int cnr,
                             TransMeta transMeta,
                             Trans disp)

Get the executing step, needed by Trans to launch a step.

Parameters:

stepMeta - The step info

stepDataInterface - the step data interface linked to this step. Here the step can store temporary data, database connections, etc.

cnr - The copy nr to get

transMeta - The transformation info

disp - The launching transformation

See Also:

StepMetaInterface.getStep(org.pentaho.di.trans.step.StepMeta, org.pentaho.di.trans.step.StepDataInterface, int, org.pentaho.di.trans.TransMeta, org.pentaho.di.trans.Trans)

getStepData

public StepDataInterface getStepData()

Get a new instance of the appropriate data class. This data class implements the StepDataInterface. It basically contains the persisting data that needs to live on, even if a worker thread is terminated.

Specified by:

getStepData in interface StepMetaInterface

Overrides:

getStepData in class AbstractStepMeta

Returns:

The appropriate StepDataInterface class.

See Also:

StepMetaInterface.getStepData()

setDefault

public void setDefault()

Set default values

See Also:

StepMetaInterface.setDefault()

getFields

public void getFields(org.pentaho.di.core.row.RowMetaInterface inputRowMeta,
                      String name,
                      org.pentaho.di.core.row.RowMetaInterface[] info,
                      StepMeta nextStep,
                      org.pentaho.di.core.variables.VariableSpace space,
                      Repository repository,
                      org.pentaho.metastore.api.IMetaStore metaStore)
               throws org.pentaho.di.core.exception.KettleStepException

Gets the fields.

Specified by:

getFields in interface StepMetaInterface

Overrides:

getFields in class BaseStepMeta

Parameters:

inputRowMeta - the input row meta that is modified in this method to reflect the output row metadata of the step

name - Name of the step to use as input for the origin field in the values

info - Fields used as extra lookup information

nextStep - the next step that is targeted

space - the space The variable space to use to replace variables

repository - the repository to use to load Kettle metadata objects impacting the output fields

metaStore - the MetaStore to use to load additional external data or metadata impacting the output fields

Throws:

org.pentaho.di.core.exception.KettleStepException - the kettle step exception

See Also:

BaseStepMeta.getFields(org.pentaho.di.core.row.RowMetaInterface, java.lang.String, org.pentaho.di.core.row.RowMetaInterface[], org.pentaho.di.trans.step.StepMeta, org.pentaho.di.core.variables.VariableSpace)

getRequiredFields

public org.pentaho.di.core.row.RowMetaInterface getRequiredFields(org.pentaho.di.core.variables.VariableSpace space)
                                                           throws org.pentaho.di.core.exception.KettleException

The natural way of data flow in a transformation is source-to-target. However, this makes mapping to target tables difficult to do. To help out here, we supply information to the transformation meta-data model about which fields are required for a step. This allows us to automate certain tasks like the mapping to pre-defined tables. The Table Output step in this case will output the fields in the target table using this method. This default implementation returns an empty row meaning that no fields are required for this step to operate.

Specified by:

getRequiredFields in interface StepMetaInterface

Overrides:

getRequiredFields in class BaseStepMeta

Parameters:

space - the variable space to use to do variable substitution.

Returns:

the required fields for this steps meta data.

Throws:

org.pentaho.di.core.exception.KettleException - in case the required fields can't be determined

See Also:

BaseStepMeta.getRequiredFields(org.pentaho.di.core.variables.VariableSpace)

clone

public Object clone()

Make an exact copy of this step, make sure to explicitly copy Collections etc.

Specified by:

clone in interface StepMetaInterface

Overrides:

clone in class BaseStepMeta

Returns:

an exact copy of this step

See Also:

BaseStepMeta.clone()

getFastloadPath

public StringPluginProperty getFastloadPath()

Returns:

the fastloadPath

setFastloadPath

public void setFastloadPath(StringPluginProperty fastloadPath)

Parameters:

fastloadPath - the fastloadPath to set

getControlFile

public StringPluginProperty getControlFile()

Returns:

the controlFile

setControlFile

public void setControlFile(StringPluginProperty controlFile)

Parameters:

controlFile - the controlFile to set

getDataFile

public StringPluginProperty getDataFile()

Returns:

the dataFile

setDataFile

public void setDataFile(StringPluginProperty dataFile)

Parameters:

dataFile - the dataFile to set

getLogFile

public StringPluginProperty getLogFile()

Returns:

the logFile

setLogFile

public void setLogFile(StringPluginProperty logFile)

Parameters:

logFile - the logFile to set

getSessions

public IntegerPluginProperty getSessions()

Returns:

the sessions

setSessions

public void setSessions(IntegerPluginProperty sessions)

Parameters:

sessions - the sessions to set

getErrorLimit

public IntegerPluginProperty getErrorLimit()

Returns:

the errorLimit

setErrorLimit

public void setErrorLimit(IntegerPluginProperty errorLimit)

Parameters:

errorLimit - the errorLimit to set

getUseControlFile

public BooleanPluginProperty getUseControlFile()

Returns:

the useControlFile

setUseControlFile

public void setUseControlFile(BooleanPluginProperty useControlFile)

Parameters:

useControlFile - the useControlFile to set

getTargetTable

public StringPluginProperty getTargetTable()

Returns:

the targetTable

setTargetTable

public void setTargetTable(StringPluginProperty targetTable)

Parameters:

targetTable - the targetTable to set

getTruncateTable

public BooleanPluginProperty getTruncateTable()

Returns:

the truncateTable

setTruncateTable

public void setTruncateTable(BooleanPluginProperty truncateTable)

Parameters:

truncateTable - the truncateTable to set

getTableFieldList

public StringListPluginProperty getTableFieldList()

Returns:

the tableFieldList

setTableFieldList

public void setTableFieldList(StringListPluginProperty tableFieldList)

Parameters:

tableFieldList - the tableFieldList to set

getStreamFieldList

public StringListPluginProperty getStreamFieldList()

Returns:

the streamFieldList

setStreamFieldList

public void setStreamFieldList(StringListPluginProperty streamFieldList)

Parameters:

streamFieldList - the streamFieldList to set

getVariableSubstitution

public BooleanPluginProperty getVariableSubstitution()

Returns:

the variableSubstitution

setVariableSubstitution

public void setVariableSubstitution(BooleanPluginProperty variableSubstitution)

Parameters:

variableSubstitution - the variableSubstitution to set