public class X100Connector35 extends X100Connector
connectionID, dbName, hostName, initBlockLock, JDBC_INGRES_PREFIX, LOG, paxGroupList, paxGroupMap, port, pwd, tableName, tabPaxInfo, url, userName
Constructor and Description |
---|
X100Connector35(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() |
int |
getSortKeySize()
This method gives total number of Sort Keys available in table
|
long |
getTupleCount() |
int[] |
getUniqueKeys(int keyIndex) |
int |
getUniqueKeySize()
This method gives total number of Unique Keys available in table
|
int |
initParallelCommit(int numClients)
Initializes parallel commit
|
int |
initParallelCommit(X100NetAppendFlags flag,
int numClients)
this method will initiate a parallelCommit transaction with
given number of clients
|
closePax, closePaxGroup, commit, disconnect, getColumnName, getColumnsForPaxGroup, getColumnType, getConnectionID, getNumCols, getNumPaxGroups, getPaxGroupByColumn, getPaxGroupsInfo, getTableName, getTabPaxInfo, getX100DataType, isCoulmnNullable, openPax, openPaxGroup, parallelCommit
public X100Connector35(String host, String port, String dbName, String tableName, String user, String password, String schema) throws ConnectionException
ConnectionException
public int initParallelCommit(X100NetAppendFlags flag, int numClients)
--
- numClients -- Number of clients involved in loading the data.
For the load to succeed, these many number ofpublic int initParallelCommit(int numClients)
IX100Connector
numClients
- -- Number of reducers that will be committing datapublic int getSortKeySize()
public int getUniqueKeySize()
public int[] getSortKeys()
public int[] getUniqueKeys(int keyIndex)
public long getTupleCount()
public X100APIVersion getAPIVersion()
IX100Connector
Copyright © 2016 Actian Corporation. All Rights Reserved.