com.actian.vw.connector.jni

Class X100BlockLoader

java.lang.Object

com.actian.vw.connector.jni.X100BlockLoader

All Implemented Interfaces:

IX100BlockLoader

Direct Known Subclasses:

X100BlockLoader30, X100BlockLoader35

public class X100BlockLoader
extends Object
implements IX100BlockLoader

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
X100BlockLoader(int paxGroup, long connectionIndex, long paxIter, long paxGroupCtx, long tabPaxInfo) BlockLoader class is for a given paxGroup

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

paxGroup

protected int paxGroup

connectionId

protected long connectionId

paxIter

protected long paxIter

paxGroupCtx

protected long paxGroupCtx

tabPaxInfo

protected long tabPaxInfo

isPrimary

protected boolean isPrimary

Constructor Detail

X100BlockLoader

public X100BlockLoader(int paxGroup,
               long connectionIndex,
               long paxIter,
               long paxGroupCtx,
               long tabPaxInfo)

BlockLoader class is for a given paxGroup

Parameters:

paxGroup -

Method Detail

setPrimaryKey

public void setPrimaryKey(boolean b)

allocateMemory

protected long allocateMemory(int size)

initPaxBlock

public boolean initPaxBlock()

This method should invoke following functions

Specified by:

initPaxBlock in interface IX100BlockLoader

Returns:

createX100Block

public int createX100Block(String tableName,
                  int paxGrpId,
                  int jobId,
                  ByteBuffer[] data,
                  int numTuples,
                  int blockID,
                  X100AddBlockStatus status,
                  long[] nativeMemPointers,
                  long dtp)
                    throws X100BlockException

Throws:

X100BlockException

flushBlock

public long flushBlock()