public final class LoadActianVector extends CompositeOperator
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_VECTOR_H_INSTANCE |
static String |
DEFAULT_VECTOR_INSTANCE |
static int |
DEFAULT_VECTOR_PORT |
static int |
DEFAULT_VECTOR_SIZE |
Constructor and Description |
---|
LoadActianVector() |
Modifier and Type | Method and Description |
---|---|
protected void |
compose(CompositionContext context)
Compose the body of this operator.
|
String |
getCharset()
Get the character set used when staging and loading for vwload method for Vectorwise operator.
|
boolean |
getCleanData()
Get whether clean data is enabled or disabled.
|
String |
getDatabase()
Get the database name.
|
boolean |
getDecimalTruncationError()
Get whether errors on decimal truncation is enabled or disabled.
|
Map<String,String> |
getExtraProperties()
Get any extra JDBC properties for the connection.
|
String |
getFinalizeTableSQL()
Retrieves the SQL statement to execute after processing all the records.
|
String |
getHost()
Get the server host name property.
|
String |
getInitializeTableSQL()
Retrieves the SQL statement to execute before processing any records.
|
RecordPort |
getInputPort() |
String |
getInsertMode()
Get insert mode used during Direct loading ( DEFAULT/ROW/BULK).
|
String |
getInstance()
Get the Actian Vector instance name.
|
boolean |
getJdbcOnly()
Get whether JDBC connections should be used instead of the command line when possible.
|
String |
getJdbcUrl()
Gets the jdbc connection url that should be explicitly used.
|
int |
getMaxErrors()
Get the maximum number of errors allowed.
|
LoadMethod |
getMethod()
Get the load method in use.
|
String |
getNullIndicator()
Get the null indicator used if the loading method stages the files.
|
String |
getPassword()
Get the password.
|
int |
getPort()
Get the Actian Vector instance port.
|
RecordPort |
getRejectPort()
Gets the port providing records which failed the load.
|
String |
getRejectsPath()
Get the rejects path.
|
Map<String,String> |
getRenameMapping()
Get the source to target field mapping.
|
boolean |
getRollback()
Get whether rollback is enabled or disabled.
|
String |
getSshPassword()
Password for SSH User id.
|
String |
getSshUser()
OS user id used to connect to Master Node of installation.
|
boolean |
getStringTruncationError()
Get whether errors on string truncation is enabled or disabled.
|
String |
getTable()
Get the target table name.
|
String |
getTmpDirectory()
Get the temporary directory that is used for storing intermediate loader files.
|
String |
getUser()
Get the user account name.
|
int |
getVectorSize()
Get the buffer size (in rows).
|
void |
setCharset(String charsetName)
Set the character set used for data staging and loading for vwload load method.
|
void |
setCleanData(boolean cleanData)
Enable or disable data cleaning.
|
void |
setDatabase(String database)
Set the database name.
|
void |
setDecimalTruncationError(boolean enableDecimalTruncationError)
Set whether errors on decimal truncation is enabled or disabled.
|
void |
setExtraProperties(Map<String,String> extraProperties)
Set any extra JDBC properties for the connection.
|
void |
setFinalizeTableSQL(String finalizeTableSQL)
Sets the SQL statements to execute after processing all the records.
|
void |
setHost(String hostName)
Set the host name property.
|
void |
setInitializeTableSQL(String initializeTableSQL)
Sets the SQL statements to execute before processing any record(s).
|
void |
setInsertMode(String insertMode)
Set insert mode statement that applies for Insert and Merge operation when Direct loading.
|
void |
setInstance(String instance)
Set the Actian Vector instance name.
|
void |
setJdbcOnly(boolean jdbcOnly)
Set whether JDBC connections should be used instead of the command line when possible.
|
void |
setJdbcUrl(String jdbcUrl)
Sets the jdbc connection url that should explicitly be used.
|
void |
setMaxErrors(int maxErrors)
Set the maximum number of errors allowed per stream before rolling back the data load operation.
|
void |
setMethod(LoadMethod method)
Set the load method to use.
|
void |
setNullIndicator(String nullIndicator)
Sets the null indicator used if the loading method stages the files.
|
void |
setPassword(String password)
Set the user's password.
|
void |
setPort(int port)
Set the Actian Vector instance port.
|
void |
setRejectsPath(String rejectsPath)
Set the rejects path.
|
void |
setRenameMapping(Map<String,String> renameMapping)
Set a rename mapping.
|
void |
setRollback(boolean enabled)
Enable or disable rollback processing.
|
void |
setSshPassword(String passwd)
Set the password for SSH user id.
|
void |
setSshUser(String user)
Set the OS User Id used for authenticating SSH connection to Master Node of Vector.
|
void |
setStringTruncationError(boolean enableStringTruncationError)
Set whether errors on string truncation is enabled or disabled.
|
void |
setTable(String table)
Set the name of the table to load.
|
void |
setTmpDirectory(String tmpDirectory)
Set the temporary directory that is to be used for storing the intermediate loader files.
|
void |
setUser(String userName)
Set the user name.
|
void |
setVectorSize(int vectorSize)
Set the size of the buffer (in rows)
used to cache data before sending to
the Vector engine.
|
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public static final int DEFAULT_VECTOR_SIZE
public static final int DEFAULT_VECTOR_PORT
public static final String DEFAULT_VECTOR_INSTANCE
public static final String DEFAULT_VECTOR_H_INSTANCE
public RecordPort getInputPort()
public RecordPort getRejectPort()
false
or null
public LoadMethod getMethod()
public void setMethod(LoadMethod method)
mode
- load method (vwload is the default)public String getHost()
public void setHost(String hostName)
hostName
- Actian Vector server host namepublic String getDatabase()
public void setDatabase(String database)
databaseName
- database namepublic String getInstance()
public void setInstance(String instance)
instanceName
- instance namepublic int getPort()
public void setPort(int port)
port
- port numberpublic String getTable()
public void setTable(String table)
tableName
- target table name.public String getUser()
public void setUser(String userName)
When using the vwload load method, the user name is not always needed. The vwload utility has to be executed by the DBA user. The user name and password supplied is for a user account that has write/copy access to the target table.
userName
- user account namepublic String getPassword()
public void setPassword(String password)
When using the vwload load method, the password is not always needed. The vwload utility has to be executed by the DBA user. The user name and password supplied is for a user account that has write/copy access to the target table.
password
- public Map<String,String> getRenameMapping()
public void setRenameMapping(Map<String,String> renameMapping)
This is an optional property. If not provided, the input fields are mapped to the target database table by schema order.
renameMapping
- the mapping from old to new names.public String getInitializeTableSQL()
public void setInitializeTableSQL(String initializeTableSQL)
CREATE TABLE
statement to create the table.
Multiple SQL CREATE, INSERT, UPDATE, DELETE or DROP statements separated by semicolon (;) can be executed.
These statements are executed only once, regardless of #partitionCount
.
initializeTableSQL
- the SQL statement to execute before processing any recordspublic String getFinalizeTableSQL()
public void setFinalizeTableSQL(String finalizeTableSQL)
CREATE INDEX
statement.
Multiple SQL CREATE, INSERT, UPDATE, DELETE or DROP statements separated by semicolon (;) can be executed.
This statement is executed only once, regardless of #partitionCount
.
finalizeTableSQL
- the SQL statement to execute after processing all the recordspublic int getMaxErrors()
public void setMaxErrors(int maxErrors)
maxErrors
- maximum errors allowed per streampublic boolean getRollback()
public void setRollback(boolean enabled)
If disabled, the operation is still aborted when the maximum number of errors has been encountered. However, the data load is not rolled back. Any data successfully loaded will appear in the target table.
rollback
- enable (true) or disable (false) rollbackpublic int getVectorSize()
public void setVectorSize(int vectorSize)
vectorSize
- buffer size in rowspublic String getRejectsPath()
public void setRejectsPath(String rejectsPath)
rejectsPath
- target path namepublic boolean getCleanData()
public void setCleanData(boolean cleanData)
cleanData
- enable (true) or disable (false) data cleaningpublic String getInsertMode()
public void setInsertMode(String insertMode)
insertMode
- insert mode for inserts and merges.public String getSshUser()
public void setSshUser(String user)
user
- public void setSshPassword(String passwd)
password
- for user idpublic String getSshPassword()
public boolean getStringTruncationError()
public void setStringTruncationError(boolean enableStringTruncationError)
stringTruncationError
- enable(true) or disable(false) errors on string truncationpublic boolean getDecimalTruncationError()
public void setDecimalTruncationError(boolean enableDecimalTruncationError)
stringTruncationError
- enable(true) or disable(false) errors on string truncationpublic String getTmpDirectory()
public void setTmpDirectory(String tmpDirectory)
tmpDirectory
- path to the temporary directorypublic String getCharset()
public void setCharset(String charsetName)
charsetName
- character set used when staging and loading for vwload methodpublic String getNullIndicator()
public void setNullIndicator(String nullIndicator)
nullIndicator
- public boolean getJdbcOnly()
public void setJdbcOnly(boolean jdbcOnly)
jdbcOnly
- enable(true) or disable(false) using JDBC exclusively if possiblepublic void setExtraProperties(Map<String,String> extraProperties)
extraProperties
- key value settings that will be applied to the JDBC connectionpublic Map<String,String> getExtraProperties()
public void setJdbcUrl(String jdbcUrl)
jdbcUrl
- url used to connect to jdbcpublic String getJdbcUrl()
protected void compose(CompositionContext context)
CompositeOperator
OperatorComposable.add(O)
OperatorComposable.connect(P, P)
. This includes
connections from the composite's input ports to sub-operators, connections between sub-operators, and
connections from sub-operators output ports to the composite's output portscompose
in class CompositeOperator
context
- the contextCopyright © 2021 Actian Corporation. All rights reserved.