public interface IX100Connector
Modifier and Type | Method and Description |
---|---|
int |
closePax(long paxIter) |
int |
closePaxGroup(long paxGroupCtx) |
void |
disconnect()
Disconnects all cached connections
|
X100APIVersion |
getAPIVersion()
Returns the X100 API Version
|
String |
getColumnName(int i) |
int[] |
getColumnsForPaxGroup(int paxIndex) |
String |
getColumnType(int i) |
long |
getConnectionID() |
int |
getNumPaxGroups() |
int[] |
getPaxGroupsInfo() |
int[] |
getSortKeys() |
int |
getSortKeySize()
This method gives total number of Sort Keys available in table
|
long |
getTabPaxInfo(String tableName) |
long |
getTupleCount() |
int[] |
getUniqueKeys(int keyIndex) |
int |
getUniqueKeySize()
This method gives total number of Unique Keys available in table
|
long |
getX100DataType(int paxIndex) |
int |
initParallelCommit(int jobsNumber)
Initializes parallel commit
|
int |
initParallelCommit(X100NetAppendFlags flag,
int jobsNumber)
Initializes parallel commit
|
boolean |
isCoulmnNullable(int i) |
long |
openPax(String table,
int paxGroup,
int partNo) |
long |
openPaxGroup(long tabPaxInfo,
int paxGroup) |
int |
parallelCommit(int jobID) |
void disconnect()
int initParallelCommit(X100NetAppendFlags flag, int jobsNumber)
index
- -- Indicates the connectionjobsNumber
- -- Number of reducers that will be committing dataint initParallelCommit(int jobsNumber)
index
- -- Indicates the connectionjobsNumber
- -- Number of reducers that will be committing dataX100APIVersion getAPIVersion()
long getTabPaxInfo(String tableName)
int closePax(long paxIter)
int parallelCommit(int jobID)
long openPaxGroup(long tabPaxInfo, int paxGroup)
long openPax(String table, int paxGroup, int partNo)
long getConnectionID()
int[] getColumnsForPaxGroup(int paxIndex)
String getColumnType(int i)
boolean isCoulmnNullable(int i)
long getX100DataType(int paxIndex)
int closePaxGroup(long paxGroupCtx)
int[] getPaxGroupsInfo()
int getNumPaxGroups()
String getColumnName(int i)
int getSortKeySize()
int getUniqueKeySize()
int[] getSortKeys()
int[] getUniqueKeys(int keyIndex)
long getTupleCount()
Copyright © 2015 Actian Corporation. All Rights Reserved.