LoadActianVector
; use that operator instead.@Deprecated public final class LoadVectorOnHadoopDirect extends CompositeOperator
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_VECTOR_H_INSTANCE
Deprecated.
|
static int |
DEFAULT_VECTOR_SIZE
Deprecated.
|
Constructor and Description |
---|
LoadVectorOnHadoopDirect()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
compose(CompositionContext context)
Deprecated.
Compose the body of this operator.
|
String |
getDatabase()
Deprecated.
Get the database name.
|
String |
getFinalizeTableSQL()
Deprecated.
Retrieves the SQL statement to execute after processing all the records.
|
String |
getHost()
Deprecated.
Get the host name of the server where the leader node is running.
|
String |
getInitializeTableSQL()
Deprecated.
Retrieves the SQL statement to execute before processing any records.
|
RecordPort |
getInputPort()
Deprecated.
|
String |
getInsertMode()
Deprecated.
Get insert mode ( DEFAULT/ROW/BULK).
|
String |
getInstance()
Deprecated.
Get the Vector instance name.
|
int |
getMaxErrors()
Deprecated.
Get the maximum number of errors allowed.
|
String |
getPassword()
Deprecated.
Get user's password.
|
RecordPort |
getRejectPort()
Deprecated.
Gets the port providing records which failed the load.
|
Map<String,String> |
getRenameMapping()
Deprecated.
Get the source to target field mapping.
|
boolean |
getRollback()
Deprecated.
Get whether rollback is enabled or disabled.
|
String |
getTable()
Deprecated.
Get the target table name.
|
String |
getUser()
Deprecated.
Get the user account name.
|
int |
getVectorSize()
Deprecated.
Get the buffer size (in rows).
|
void |
setDatabase(String database)
Deprecated.
Set the database name.
|
void |
setFinalizeTableSQL(String finalizeTableSQL)
Deprecated.
Sets the multiple SQL statements to execute after processing all the records.
|
void |
setHost(String host)
Deprecated.
Set the host name of the server where the leader node is running.
|
void |
setInitializeTableSQL(String initializeTableSQL)
Deprecated.
Sets the multiple SQL statements to execute before processing any record(s).
|
void |
setInsertMode(String insertMode)
Deprecated.
Set insert mode statement applies for Insert and Merge operation.
|
void |
setInstance(String instance)
Deprecated.
Set the Vector instance name.
|
void |
setMaxErrors(int maxErrors)
Deprecated.
Set the maximum number of errors allowed per stream before rolling back the data load operation.
|
void |
setPassword(String password)
Deprecated.
Set user's password.
|
void |
setRenameMapping(Map<String,String> renameMapping)
Deprecated.
Set a rename mapping.
|
void |
setRollback(boolean enabled)
Deprecated.
Enable or disable rollback processing.
|
void |
setTable(String table)
Deprecated.
Set the name of the table to load.
|
void |
setUser(String user)
Deprecated.
Set the user account name.
|
void |
setVectorSize(int vectorSize)
Deprecated.
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 String DEFAULT_VECTOR_H_INSTANCE
public String getUser()
public void setUser(String user)
user
- the name of the user account that has write/copy permissionspublic String getPassword()
public void setPassword(String password)
password
- the password of the user account having write/copy permissionspublic 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 String getHost()
public void setHost(String host)
host
- the server host name of the leader nodepublic String getInstance()
public void setInstance(String instance)
instance
- the instance namepublic String getDatabase()
public void setDatabase(String database)
database
- the database namepublic String getTable()
public void setTable(String table)
table
- the name of the target table.public int getVectorSize()
public void setVectorSize(int vectorSize)
vectorSize
- buffer size in rowspublic RecordPort getInputPort()
public RecordPort getRejectPort()
false
or null
public String getInsertMode()
public void setInsertMode(String insertMode)
insertMode
- insert mode for inserts and merges.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 © 2024 Actian Corporation. All rights reserved.