public class X100Connector30 extends X100Connector
connectionID, dbName, hostName, initBlockLock, JDBC_INGRES_PREFIX, LOG, paxGroupList, paxGroupMap, port, pwd, tableName, tabPaxInfo, url, userName
Constructor and Description |
---|
X100Connector30(String host,
String port,
String dbName,
String tableName,
String user,
String password,
String schema) |
Modifier and Type | Method and Description |
---|---|
X100APIVersion |
getAPIVersion()
Returns the X100 API Version
|
int[] |
getSortKeys()
this method is not implemented
|
int |
getSortKeySize()
This method is not implemented.
|
long |
getTupleCount()
This method is not implemented
|
int[] |
getUniqueKeys(int keyIndex)
This method is not implemented
|
int |
getUniqueKeySize()
This method is not implemented.
|
int |
initParallelCommit(int numClients)
this method will initiate a parallelCommit transaction with
given number of clients
|
int |
initParallelCommit(X100NetAppendFlags flag,
int jobsNumber)
Initializes parallel commit
|
closePax, closePaxGroup, commit, disconnect, getColumnName, getColumnsForPaxGroup, getColumnType, getConnectionID, getNumCols, getNumPaxGroups, getPaxGroupByColumn, getPaxGroupsInfo, getTableName, getTabPaxInfo, getX100DataType, isCoulmnNullable, openPax, openPaxGroup, parallelCommit
public X100Connector30(String host, String port, String dbName, String tableName, String user, String password, String schema) throws ConnectionException
ConnectionException
public int initParallelCommit(int numClients)
--
- numClients -- Number of clients involved in loading the data.
For the load to succeed, these many number ofpublic int initParallelCommit(X100NetAppendFlags flag, int jobsNumber)
IX100Connector
jobsNumber
- -- Number of reducers that will be committing datapublic X100APIVersion getAPIVersion()
IX100Connector
public int getSortKeySize()
public int getUniqueKeySize()
public int[] getSortKeys()
public int[] getUniqueKeys(int keyIndex)
public long getTupleCount()
Copyright © 2015 Actian Corporation. All Rights Reserved.