public class X100BlockLoader extends Object implements IX100BlockLoader
Modifier and Type | Field and Description |
---|---|
protected long |
connectionId |
protected boolean |
isPrimary |
static org.apache.commons.logging.Log |
LOG |
protected int |
paxGroup |
protected long |
paxGroupCtx |
protected long |
paxIter |
protected long |
tabPaxInfo |
Constructor and Description |
---|
X100BlockLoader(int paxGroup,
long connectionIndex,
long paxIter,
long paxGroupCtx,
long tabPaxInfo)
BlockLoader class is for a given paxGroup
|
Modifier and Type | Method and Description |
---|---|
protected long |
allocateMemory(int size) |
int |
createX100Block(String tableName,
int paxGrpId,
int jobId,
ByteBuffer[] data,
int numTuples,
int blockID,
X100AddBlockStatus status,
long[] nativeMemPointers,
long dtp) |
long |
flushBlock() |
boolean |
initPaxBlock()
This method should invoke following functions
|
void |
setPrimaryKey(boolean b) |
public static final org.apache.commons.logging.Log LOG
protected int paxGroup
protected long connectionId
protected long paxIter
protected long paxGroupCtx
protected long tabPaxInfo
protected boolean isPrimary
public X100BlockLoader(int paxGroup, long connectionIndex, long paxIter, long paxGroupCtx, long tabPaxInfo)
paxGroup
- public void setPrimaryKey(boolean b)
protected long allocateMemory(int size)
public boolean initPaxBlock()
initPaxBlock
in interface IX100BlockLoader
public int createX100Block(String tableName, int paxGrpId, int jobId, ByteBuffer[] data, int numTuples, int blockID, X100AddBlockStatus status, long[] nativeMemPointers, long dtp) throws X100BlockException
X100BlockException
public long flushBlock()
Copyright © 2016 Actian Corporation. All Rights Reserved.