com.actian.vw.connector.writer

Class ParallelWriter

java.lang.Object

com.actian.vw.connector.writer.ParallelWriter

All Implemented Interfaces:

IWriter

public class ParallelWriter
extends Object
implements IWriter

This is a test client to demonstrate loading data to Vectorwise using VWLoad Java API This program will read a csv file from local file system and loads it to VW table. It expects the csv file to be in same format as columns in table

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELIMITER

Fields inherited from interface com.actian.vw.connector.writer.IWriter

TRANSACTION_LIMIT

Constructor Summary

Constructors

Constructor and Description
ParallelWriter(String jdbcURL, String user, String pwd, String tableName, int jid, int blockId, String delim, int txnLimit)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanUp()
void	collectData(int colIndex, String data) Add data in array for every column
int	commit() Issues parallel commit to all columns
void	init()
void	writeData()

Methods inherited from class java.lang.Object

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

Field Detail

DELIMITER

public static final String DELIMITER

See Also:

Constant Field Values

Constructor Detail

ParallelWriter

public ParallelWriter(String jdbcURL,
              String user,
              String pwd,
              String tableName,
              int jid,
              int blockId,
              String delim,
              int txnLimit)
               throws ConnectionException

Throws:

ConnectionException

Method Detail

init

public void init()
          throws ConnectionException

Throws:

ConnectionException

collectData

public void collectData(int colIndex,
               String data)

Add data in array for every column

Specified by:

collectData in interface IWriter

Parameters:

colIndex - -- index of the column

data - -- value of the column

writeData

public void writeData()
               throws InterruptedException

Specified by:

writeData in interface IWriter

Throws:

InterruptedException

commit

public int commit()
           throws X100BlockException

Issues parallel commit to all columns

Returns:

Throws:

X100BlockException

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface IWriter