public class TeraFastMeta extends AbstractStepMeta
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 |
loggingObject, STEP_ATTRIBUTES_FILE
Constructor and Description |
---|
TeraFastMeta() |
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) |
getConnectionName, getDbMeta, getProperties, getPropertyFactory, getXML, loadXML, readFromPreferences, readRep, saveAsPreferences, saveRep, setConnectionName, setDbMeta
analyseImpact, analyseImpact, cancelQueries, check, check, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, findAttribute, findParent, 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
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
analyseImpact, analyseImpact, cancelQueries, check, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, 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
public static final PluginMessages MESSAGES
public static final String DEFAULT_FASTLOAD_PATH
public static final String DEFAULT_DATA_FILE
public static final String DEFAULT_TARGET_TABLE
public static final int DEFAULT_SESSIONS
public static final boolean DEFAULT_TRUNCATETABLE
public static final boolean DEFAULT_VARIABLE_SUBSTITUTION
public static final int DEFAULT_ERROR_LIMIT
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)
check
in interface StepMetaInterface
check
in class BaseStepMeta
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 fieldsStepMetaInterface.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)
public String getQuotedSchemaTableName(org.pentaho.di.core.variables.VariableSpace space) throws org.pentaho.di.core.exception.KettleException
space
- the variableSpace to be used.org.pentaho.di.core.exception.KettleException
- if no table specified.public org.pentaho.di.core.database.Database connectToDatabase() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
- if an error occurs.public StepInterface getStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta, Trans disp)
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 transformationStepMetaInterface.getStep(org.pentaho.di.trans.step.StepMeta,
org.pentaho.di.trans.step.StepDataInterface, int, org.pentaho.di.trans.TransMeta,
org.pentaho.di.trans.Trans)
public StepDataInterface getStepData()
getStepData
in interface StepMetaInterface
getStepData
in class AbstractStepMeta
StepMetaInterface.getStepData()
public void setDefault()
StepMetaInterface.setDefault()
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
getFields
in interface StepMetaInterface
getFields
in class BaseStepMeta
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 fieldsorg.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionBaseStepMeta.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)
public org.pentaho.di.core.row.RowMetaInterface getRequiredFields(org.pentaho.di.core.variables.VariableSpace space) throws org.pentaho.di.core.exception.KettleException
getRequiredFields
in interface StepMetaInterface
getRequiredFields
in class BaseStepMeta
space
- the variable space to use to do variable substitution.org.pentaho.di.core.exception.KettleException
- in case the required fields can't be determinedBaseStepMeta.getRequiredFields(org.pentaho.di.core.variables.VariableSpace)
public Object clone()
clone
in interface StepMetaInterface
clone
in class BaseStepMeta
BaseStepMeta.clone()
public StringPluginProperty getFastloadPath()
public void setFastloadPath(StringPluginProperty fastloadPath)
fastloadPath
- the fastloadPath to setpublic StringPluginProperty getControlFile()
public void setControlFile(StringPluginProperty controlFile)
controlFile
- the controlFile to setpublic StringPluginProperty getDataFile()
public void setDataFile(StringPluginProperty dataFile)
dataFile
- the dataFile to setpublic StringPluginProperty getLogFile()
public void setLogFile(StringPluginProperty logFile)
logFile
- the logFile to setpublic IntegerPluginProperty getSessions()
public void setSessions(IntegerPluginProperty sessions)
sessions
- the sessions to setpublic IntegerPluginProperty getErrorLimit()
public void setErrorLimit(IntegerPluginProperty errorLimit)
errorLimit
- the errorLimit to setpublic BooleanPluginProperty getUseControlFile()
public void setUseControlFile(BooleanPluginProperty useControlFile)
useControlFile
- the useControlFile to setpublic StringPluginProperty getTargetTable()
public void setTargetTable(StringPluginProperty targetTable)
targetTable
- the targetTable to setpublic BooleanPluginProperty getTruncateTable()
public void setTruncateTable(BooleanPluginProperty truncateTable)
truncateTable
- the truncateTable to setpublic StringListPluginProperty getTableFieldList()
public void setTableFieldList(StringListPluginProperty tableFieldList)
tableFieldList
- the tableFieldList to setpublic StringListPluginProperty getStreamFieldList()
public void setStreamFieldList(StringListPluginProperty streamFieldList)
streamFieldList
- the streamFieldList to setpublic BooleanPluginProperty getVariableSubstitution()
public void setVariableSubstitution(BooleanPluginProperty variableSubstitution)
variableSubstitution
- the variableSubstitution to set