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 void
allocate(int nrRows)
Object
clone()
Make an exact copy of this step, make sure to explicitly copy Collections etc.String
getBufferSize()
org.pentaho.di.core.database.DatabaseMeta
getDatabaseMeta()
Returns the database meta for this stepString
getDelimiter()
String
getEncoding()
String
getErrorFileName()
String[]
getFieldDatabase()
String[]
getFieldFormat()
String[]
getFieldStream()
String
getFifoFileName()
String
getMaxNrErrors()
String
getMissingDatabaseConnectionInformationMessage()
Provides a way for this object to return a custom message when database connection information is incomplete or missing.String
getSchemaName()
Returns the schema name for this step.String
getSqlPath()
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)
Standard method to return an SQLStatement object with SQL statements that the step needs in order to work correctly.StepInterface
getStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr, Trans trans)
Get the executing step, needed by Trans to launch a step.StepDataInterface
getStepData()
Get a new instance of the appropriate data class.String
getTableName()
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.String
getXML()
Produces the XML string that describes this step's information.boolean
isContinueOnError()
boolean
isEscapingSpecialCharacters()
boolean
isRejectErrors()
boolean
isTruncatingTable()
boolean
isUseAuthentication()
boolean
isUseDynamicVNode()
boolean
isUseSSV()
boolean
isUseStandardConversion()
boolean
isUsingVwload()
void
loadXML(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 Nodevoid
readRep(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 repositoryvoid
saveRep(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 repositoryvoid
setBufferSize(String bufferSize)
void
setContinueOnError(boolean continueOnError)
void
setDatabaseMeta(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
void
setDefault()
Set default valuesvoid
setDelimiter(String delimiter)
void
setEncoding(String encoding)
void
setErrorFileName(String errorFileName)
void
setEscapingSpecialCharacters(boolean escapingSpecialCharacters)
void
setFieldDatabase(String[] fieldDatabase)
void
setFieldFormat(String[] fieldFormat)
void
setFieldStream(String[] fieldStream)
void
setFifoFileName(String fifoFileName)
void
setMaxNrErrors(String maxNrErrors)
void
setRejectErrors(boolean rejectErrors)
void
setSqlPath(String sqlPath)
void
setTablename(String tablename)
void
setTruncatingTable(boolean truncatingTable)
void
setUseAuthentication(boolean useAuthentication)
void
setUseDynamicVNode(boolean createDynamicVNode)
void
setUseSSV(boolean useSSV)
void
setUseStandardConversion(boolean useStandardConversion)
void
setUsingVwload(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:
getStep
in 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:
getStepData
in 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:
clone
in interfaceStepMetaInterface
- Overrides:
clone
in classBaseStepMeta
- Returns:
- an exact copy of this step
- See Also:
BaseStepMeta.clone()
-
setDefault
public void setDefault()
Description copied from interface:StepMetaInterface
Set default values- Specified by:
setDefault
in 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:BaseStepMeta
Produces the XML string that describes this step's information.- Specified by:
getXML
in interfaceStepMetaInterface
- Overrides:
getXML
in 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:StepMetaInterface
Load the values for this step from an XML Node- Specified by:
loadXML
in interfaceStepMetaInterface
- Overrides:
loadXML
in 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:StepMetaInterface
Read the steps information from a Kettle repository- Specified by:
readRep
in interfaceStepMetaInterface
- Overrides:
readRep
in 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:StepMetaInterface
Save the steps data into a Kettle repository- Specified by:
saveRep
in interfaceStepMetaInterface
- Overrides:
saveRep
in 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:ProvidesDatabaseConnectionInformation
Returns the database meta for this step- Specified by:
getDatabaseMeta
in 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:ProvidesDatabaseConnectionInformation
Returns the table name for this step- Specified by:
getTableName
in 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:BaseStepMeta
Standard 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:
getSQLStatements
in interfaceStepMetaInterface
- Overrides:
getSQLStatements
in 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:ProvidesDatabaseConnectionInformation
Returns the schema name for this step.- Specified by:
getSchemaName
in interfaceProvidesDatabaseConnectionInformation
- Returns:
-
getMissingDatabaseConnectionInformationMessage
public String getMissingDatabaseConnectionInformationMessage()
Description copied from interface:ProvidesDatabaseConnectionInformation
Provides a way for this object to return a custom message when database connection information is incomplete or missing. If this returnsnull
a default message will be displayed for missing information.- Specified by:
getMissingDatabaseConnectionInformationMessage
in 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:BaseStepMeta
This method returns all the database connections that are used by the step.- Specified by:
getUsedDatabaseConnections
in interfaceStepMetaInterface
- Overrides:
getUsedDatabaseConnections
in classBaseStepMeta
- Returns:
- an array of database connections meta-data. Return an empty array if no connections are used.
-
-