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 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
attributes, databases, log, loggingObject, parentStepMeta, repository, STEP_ATTRIBUTES_FILE
-
-
Constructor Summary
Constructors Constructor Description TeraFastMeta()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
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 valuesvoid
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, createEntry, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, extractStepMetadataEntries, findAttribute, findParent, findParentEntry, getActiveReferencedObjectDescription, getDescription, getDialogClassName, getFields, getLog, getLogChannelId, getName, getObjectCopy, getObjectId, getObjectRevision, getObjectType, getOptionalStreams, getParent, getParentStepMeta, getReferencedObjectDescriptions, getRepCode, getRepositoryDirectory, getRequiredFields, getResourceDependencies, getSQLStatements, getSQLStatements, getStepInjectionMetadataEntries, getStepIOMeta, getStepIOMeta, getStepMetaInjectionInterface, getSupportedTransformationTypes, getTableFields, getTooltip, getUsedArguments, getUsedDatabaseConnections, getUsedLibraries, getXmlCode, handleStreamSelection, hasChanged, hasRepositoryReferences, isBasic, isDebug, isDetailed, isReferencedObjectEnabled, isRowLevel, loadReferencedObject, loadReferencedObject, loadStepAttributes, loadXML, loadXML, logBasic, logBasic, logDebug, logDebug, logDetailed, logDetailed, logError, logError, logError, logMinimal, logMinimal, logRowlevel, logRowlevel, lookupRepositoryReferences, readRep, readRep, resetStepIoMeta, saveRep, searchInfoAndTargetSteps, setChanged, setChanged, setParentStepMeta, setStepIOMeta, supportsErrorHandling
-
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.pentaho.di.trans.step.StepMetaInterface
analyseImpact, analyseImpact, cancelQueries, check, cleanAfterHopFromRemove, cleanAfterHopFromRemove, cleanAfterHopToRemove, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, extractStepMetadataEntries, fetchTransMeta, getActiveReferencedObjectDescription, getDialogClassName, getFields, getOptionalStreams, getParentStepMeta, getReferencedObjectDescriptions, getResourceDependencies, getSQLStatements, getSQLStatements, getStepIOMeta, getStepMetaInjectionInterface, getSupportedTransformationTypes, getTableFields, getUsedArguments, getUsedDatabaseConnections, getUsedLibraries, handleStreamSelection, hasChanged, hasRepositoryReferences, isReferencedObjectEnabled, loadReferencedObject, loadXML, lookupRepositoryReferences, passDataToServletOutput, 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
-
-
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 interfaceStepMetaInterface
- Overrides:
check
in classBaseStepMeta
- Parameters:
remarks
- The list to put the remarks in @see org.pentaho.di.core.CheckResultstepMeta
- The stepMeta to help checkingprev
- The fields coming from the previous stepinput
- The input step namesoutput
- The output step namesinfo
- The fields that are used as information by the stepspace
- the variable space to resolve variable expressions withrepository
- the repository to use to load Kettle metadata objects impacting the output fieldsmetaStore
- 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)
-
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 infostepDataInterface
- the step data interface linked to this step. Here the step can store temporary data, database connections, etc.cnr
- The copy nr to gettransMeta
- The transformation infodisp
- 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 interfaceStepMetaInterface
- Overrides:
getStepData
in classAbstractStepMeta
- 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 interfaceStepMetaInterface
- Overrides:
getFields
in classBaseStepMeta
- Parameters:
inputRowMeta
- the input row meta that is modified in this method to reflect the output row metadata of the stepname
- Name of the step to use as input for the origin field in the valuesinfo
- Fields used as extra lookup informationnextStep
- the next step that is targetedspace
- the space The variable space to use to replace variablesrepository
- the repository to use to load Kettle metadata objects impacting the output fieldsmetaStore
- 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 interfaceStepMetaInterface
- Overrides:
getRequiredFields
in classBaseStepMeta
- 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 interfaceStepMetaInterface
- Overrides:
clone
in classBaseStepMeta
- 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
-
-