Class IngresVectorwiseLoaderMeta
- java.lang.Object
-
- org.pentaho.di.trans.step.BaseStepMeta
-
- org.pentaho.di.trans.steps.ivwloader.IngresVectorwiseLoaderMeta
-
- All Implemented Interfaces:
Cloneable,ProvidesDatabaseConnectionInformation,StepAttributesInterface,StepMetaInterface
public class IngresVectorwiseLoaderMeta extends BaseStepMeta implements StepMetaInterface, ProvidesDatabaseConnectionInformation
Metadata for the VectorWise bulk loader.
-
-
Field Summary
-
Fields inherited from class org.pentaho.di.trans.step.BaseStepMeta
attributes, databases, log, loggingObject, parentStepMeta, repository, STEP_ATTRIBUTES_FILE
-
-
Constructor Summary
Constructors Constructor Description IngresVectorwiseLoaderMeta()Default constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidallocate(int nrRows)Objectclone()Make an exact copy of this step, make sure to explicitly copy Collections etc.StringgetBufferSize()org.pentaho.di.core.database.DatabaseMetagetDatabaseMeta()Returns the database meta for this stepStringgetDelimiter()StringgetEncoding()StringgetErrorFileName()String[]getFieldDatabase()String[]getFieldFormat()String[]getFieldStream()StringgetFifoFileName()StringgetMaxNrErrors()StringgetMissingDatabaseConnectionInformationMessage()Provides a way for this object to return a custom message when database connection information is incomplete or missing.StringgetSchemaName()Returns the schema name for this step.StringgetSqlPath()org.pentaho.di.core.SQLStatementgetSQLStatements(TransMeta transMeta, StepMeta stepMeta, org.pentaho.di.core.row.RowMetaInterface prev, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)Standard method to return an SQLStatement object with SQL statements that the step needs in order to work correctly.StepInterfacegetStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr, Trans trans)Get the executing step, needed by Trans to launch a step.StepDataInterfacegetStepData()Get a new instance of the appropriate data class.StringgetTableName()Returns the table name for this steporg.pentaho.di.core.database.DatabaseMeta[]getUsedDatabaseConnections()This method returns all the database connections that are used by the step.StringgetXML()Produces the XML string that describes this step's information.booleanisContinueOnError()booleanisEscapingSpecialCharacters()booleanisRejectErrors()booleanisTruncatingTable()booleanisUseAuthentication()booleanisUseDynamicVNode()booleanisUseSSV()booleanisUseStandardConversion()booleanisUsingVwload()voidloadXML(Node stepnode, List<org.pentaho.di.core.database.DatabaseMeta> databases, org.pentaho.metastore.api.IMetaStore metaStore)Load the values for this step from an XML NodevoidreadRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.repository.ObjectId id_step, List<org.pentaho.di.core.database.DatabaseMeta> databases)Read the steps information from a Kettle repositoryvoidsaveRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step)Save the steps data into a Kettle repositoryvoidsetBufferSize(String bufferSize)voidsetContinueOnError(boolean continueOnError)voidsetDatabaseMeta(org.pentaho.di.core.database.DatabaseMeta databaseMeta)voidsetDefault()Set default valuesvoidsetDelimiter(String delimiter)voidsetEncoding(String encoding)voidsetErrorFileName(String errorFileName)voidsetEscapingSpecialCharacters(boolean escapingSpecialCharacters)voidsetFieldDatabase(String[] fieldDatabase)voidsetFieldFormat(String[] fieldFormat)voidsetFieldStream(String[] fieldStream)voidsetFifoFileName(String fifoFileName)voidsetMaxNrErrors(String maxNrErrors)voidsetRejectErrors(boolean rejectErrors)voidsetSqlPath(String sqlPath)voidsetTablename(String tablename)voidsetTruncatingTable(boolean truncatingTable)voidsetUseAuthentication(boolean useAuthentication)voidsetUseDynamicVNode(boolean createDynamicVNode)voidsetUseSSV(boolean useSSV)voidsetUseStandardConversion(boolean useStandardConversion)voidsetUsingVwload(boolean usingVwload)-
Methods inherited from class org.pentaho.di.trans.step.BaseStepMeta
analyseImpact, analyseImpact, cancelQueries, check, check, check, createEntry, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, extractStepMetadataEntries, findAttribute, findParent, findParentEntry, getActiveReferencedObjectDescription, getDescription, getDialogClassName, getFields, getFields, getLog, getLogChannelId, getName, getObjectCopy, getObjectId, getObjectRevision, getObjectType, getOptionalStreams, getParent, getParentStepMeta, getReferencedObjectDescriptions, getRepCode, getRepositoryDirectory, getRequiredFields, getRequiredFields, getResourceDependencies, getSQLStatements, getStepInjectionMetadataEntries, getStepIOMeta, getStepIOMeta, getStepMetaInjectionInterface, getSupportedTransformationTypes, getTableFields, getTooltip, getUsedArguments, 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, check, cleanAfterHopFromRemove, cleanAfterHopFromRemove, cleanAfterHopToRemove, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, extractStepMetadataEntries, fetchTransMeta, getActiveReferencedObjectDescription, getDialogClassName, getFields, getFields, getOptionalStreams, getParentStepMeta, getReferencedObjectDescriptions, getRequiredFields, getResourceDependencies, getSQLStatements, getStepIOMeta, getStepMetaInjectionInterface, getSupportedTransformationTypes, getTableFields, getUsedArguments, getUsedLibraries, handleStreamSelection, hasChanged, hasRepositoryReferences, isReferencedObjectEnabled, loadReferencedObject, loadXML, lookupRepositoryReferences, passDataToServletOutput, readRep, resetStepIoMeta, saveRep, searchInfoAndTargetSteps, setChanged, setParentStepMeta, supportsErrorHandling
-
-
-
-
Method Detail
-
getStep
public StepInterface getStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr, Trans trans)
Get the executing step, needed by Trans to launch a step.- Specified by:
getStepin interfaceStepMetaInterface- 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 gettr- The transformation infotrans- 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:
getStepDatain interfaceStepMetaInterface- Returns:
- The appropriate StepDataInterface class.
- See Also:
StepMetaInterface.getStepData()
-
clone
public Object clone()
Make an exact copy of this step, make sure to explicitly copy Collections etc.- Specified by:
clonein interfaceStepMetaInterface- Overrides:
clonein classBaseStepMeta- Returns:
- an exact copy of this step
- See Also:
BaseStepMeta.clone()
-
setDefault
public void setDefault()
Description copied from interface:StepMetaInterfaceSet default values- Specified by:
setDefaultin interfaceStepMetaInterface
-
isRejectErrors
public boolean isRejectErrors()
- Returns:
- the rejectErrors
-
setRejectErrors
public void setRejectErrors(boolean rejectErrors)
- Parameters:
rejectErrors- the rejectErrors to set.
-
allocate
public void allocate(int nrRows)
-
getXML
public String getXML()
Description copied from class:BaseStepMetaProduces the XML string that describes this step's information.- Specified by:
getXMLin interfaceStepMetaInterface- Overrides:
getXMLin classBaseStepMeta- Returns:
- String containing the XML describing this step.
-
loadXML
public void loadXML(Node stepnode, List<org.pentaho.di.core.database.DatabaseMeta> databases, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.di.core.exception.KettleXMLException
Description copied from interface:StepMetaInterfaceLoad the values for this step from an XML Node- Specified by:
loadXMLin interfaceStepMetaInterface- Overrides:
loadXMLin classBaseStepMeta- Parameters:
stepnode- the Node to get the info fromdatabases- The available list of databases to reference tometaStore- the metastore to optionally load external reference metadata from- Throws:
org.pentaho.di.core.exception.KettleXMLException- When an unexpected XML error occurred. (malformed etc.)
-
readRep
public void readRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.repository.ObjectId id_step, List<org.pentaho.di.core.database.DatabaseMeta> databases) throws org.pentaho.di.core.exception.KettleException
Description copied from interface:StepMetaInterfaceRead the steps information from a Kettle repository- Specified by:
readRepin interfaceStepMetaInterface- Overrides:
readRepin classBaseStepMeta- Parameters:
rep- The repository to read frommetaStore- The MetaStore to read external information fromid_step- The step IDdatabases- The databases to reference- Throws:
org.pentaho.di.core.exception.KettleException- When an unexpected error occurred (database, network, etc)
-
saveRep
public void saveRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step) throws org.pentaho.di.core.exception.KettleException
Description copied from interface:StepMetaInterfaceSave the steps data into a Kettle repository- Specified by:
saveRepin interfaceStepMetaInterface- Overrides:
saveRepin classBaseStepMeta- Parameters:
rep- The Kettle repository to save tometaStore- the metaStore to optionally write toid_transformation- The transformation IDid_step- The step ID- Throws:
org.pentaho.di.core.exception.KettleException- When an unexpected error occurred (database, network, etc)
-
getDatabaseMeta
public org.pentaho.di.core.database.DatabaseMeta getDatabaseMeta()
Description copied from interface:ProvidesDatabaseConnectionInformationReturns the database meta for this step- Specified by:
getDatabaseMetain interfaceProvidesDatabaseConnectionInformation- Returns:
- the databaseMeta
-
setDatabaseMeta
public void setDatabaseMeta(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
- Parameters:
databaseMeta- the databaseMeta to set
-
getTableName
public String getTableName()
Description copied from interface:ProvidesDatabaseConnectionInformationReturns the table name for this step- Specified by:
getTableNamein interfaceProvidesDatabaseConnectionInformation- Returns:
- the tablename
-
setTablename
public void setTablename(String tablename)
- Parameters:
tablename- the tablename to set
-
getFieldStream
public String[] getFieldStream()
- Returns:
- the fieldStream
-
setFieldStream
public void setFieldStream(String[] fieldStream)
- Parameters:
fieldStream- the fieldStream to set
-
getFieldDatabase
public String[] getFieldDatabase()
- Returns:
- the fieldDatabase
-
setFieldDatabase
public void setFieldDatabase(String[] fieldDatabase)
- Parameters:
fieldDatabase- the fieldDatabase to set
-
getFieldFormat
public String[] getFieldFormat()
- Returns:
- the fieldFormat
-
setFieldFormat
public void setFieldFormat(String[] fieldFormat)
- Parameters:
fieldFormat- the fieldFormat to set
-
getSQLStatements
public org.pentaho.di.core.SQLStatement getSQLStatements(TransMeta transMeta, StepMeta stepMeta, org.pentaho.di.core.row.RowMetaInterface prev, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)
Description copied from class:BaseStepMetaStandard method to return an SQLStatement object with SQL statements that the step needs in order to work correctly. This can mean "create table", "create index" statements but also "alter table ... add/drop/modify" statements.- Specified by:
getSQLStatementsin interfaceStepMetaInterface- Overrides:
getSQLStatementsin classBaseStepMeta- Parameters:
transMeta- TransInfo object containing the complete transformationstepMeta- StepMeta object containing the complete stepprev- Row containing meta-data for the input fields (no data)repository- 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- Returns:
- The SQL Statements for this step. If nothing has to be done, the SQLStatement.getSQL() == null. @see SQLStatement
-
getFifoFileName
public String getFifoFileName()
- Returns:
- the fifoFileName
-
setFifoFileName
public void setFifoFileName(String fifoFileName)
- Parameters:
fifoFileName- the fifoFileName to set
-
getSqlPath
public String getSqlPath()
- Returns:
- the sqlPath
-
setSqlPath
public void setSqlPath(String sqlPath)
- Parameters:
sqlPath- the sqlPath to set
-
getEncoding
public String getEncoding()
- Returns:
- the encoding
-
setEncoding
public void setEncoding(String encoding)
- Parameters:
encoding- the encoding to set
-
getDelimiter
public String getDelimiter()
- Returns:
- the delimiter
-
setDelimiter
public void setDelimiter(String delimiter)
- Parameters:
delimiter- the delimiter to set
-
getErrorFileName
public String getErrorFileName()
-
setErrorFileName
public void setErrorFileName(String errorFileName)
-
isContinueOnError
public boolean isContinueOnError()
-
setContinueOnError
public void setContinueOnError(boolean continueOnError)
-
isUseStandardConversion
public boolean isUseStandardConversion()
-
setUseStandardConversion
public void setUseStandardConversion(boolean useStandardConversion)
-
isUseDynamicVNode
public boolean isUseDynamicVNode()
-
setUseDynamicVNode
public void setUseDynamicVNode(boolean createDynamicVNode)
-
isUseSSV
public boolean isUseSSV()
-
setUseSSV
public void setUseSSV(boolean useSSV)
-
isEscapingSpecialCharacters
public boolean isEscapingSpecialCharacters()
- Returns:
- the escapingSpecialCharacters
-
setEscapingSpecialCharacters
public void setEscapingSpecialCharacters(boolean escapingSpecialCharacters)
- Parameters:
escapingSpecialCharacters- the escapingSpecialCharacters to set
-
getBufferSize
public String getBufferSize()
- Returns:
- the bufferSize
-
setBufferSize
public void setBufferSize(String bufferSize)
- Parameters:
bufferSize- the bufferSize to set
-
isUseAuthentication
public boolean isUseAuthentication()
- Returns:
- the useAuthentication
-
setUseAuthentication
public void setUseAuthentication(boolean useAuthentication)
- Parameters:
useAuthentication- the useAuthentication to set
-
isUsingVwload
public boolean isUsingVwload()
-
setUsingVwload
public void setUsingVwload(boolean usingVwload)
-
isTruncatingTable
public boolean isTruncatingTable()
-
setTruncatingTable
public void setTruncatingTable(boolean truncatingTable)
-
getMaxNrErrors
public String getMaxNrErrors()
-
setMaxNrErrors
public void setMaxNrErrors(String maxNrErrors)
-
getSchemaName
public String getSchemaName()
Description copied from interface:ProvidesDatabaseConnectionInformationReturns the schema name for this step.- Specified by:
getSchemaNamein interfaceProvidesDatabaseConnectionInformation- Returns:
-
getMissingDatabaseConnectionInformationMessage
public String getMissingDatabaseConnectionInformationMessage()
Description copied from interface:ProvidesDatabaseConnectionInformationProvides a way for this object to return a custom message when database connection information is incomplete or missing. If this returnsnulla default message will be displayed for missing information.- Specified by:
getMissingDatabaseConnectionInformationMessagein interfaceProvidesDatabaseConnectionInformation- Returns:
- A friendly message that describes that database connection information is missing and, potentially, why.
-
getUsedDatabaseConnections
public org.pentaho.di.core.database.DatabaseMeta[] getUsedDatabaseConnections()
Description copied from class:BaseStepMetaThis method returns all the database connections that are used by the step.- Specified by:
getUsedDatabaseConnectionsin interfaceStepMetaInterface- Overrides:
getUsedDatabaseConnectionsin classBaseStepMeta- Returns:
- an array of database connections meta-data. Return an empty array if no connections are used.
-
-