com.actian.vw.connector.writer

Class SingleWriter

java.lang.Object

com.actian.vw.connector.writer.SingleWriter

All Implemented Interfaces:

IWriter

public class SingleWriter
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
static org.apache.commons.logging.Log	LOG
static int	TRANSACTION_LIMIT

Constructor Summary

Constructors

Constructor and Description
SingleWriter(String jdbcURL, String user, String pwd, String tableName, int txnLimit)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanUp()
void	collectData(int colId, String data) Add data in array for every column
static void	main(String[] args)
void	writeData()
void	writeFile(FileInputStream is)
void	writeFile(SplitInputStream is)
void	writeFile(String fileName)

Methods inherited from class java.lang.Object

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

Field Detail

TRANSACTION_LIMIT

public static final int TRANSACTION_LIMIT

See Also:

Constant Field Values

DELIMITER

public static final String DELIMITER

See Also:

Constant Field Values

LOG

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

Constructor Detail

SingleWriter

public SingleWriter(String jdbcURL,
            String user,
            String pwd,
            String tableName,
            int txnLimit)
             throws ConnectionException

Throws:

ConnectionException

Method Detail

collectData

public void collectData(int colId,
               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

writeFile

public void writeFile(FileInputStream is)
               throws IOException,
                      InterruptedException

Parameters:

is -

Throws:

IOException

InterruptedException

writeFile

public void writeFile(SplitInputStream is)
               throws IOException,
                      InterruptedException

Parameters:

is -

Throws:

IOException

InterruptedException

writeFile

public void writeFile(String fileName)
               throws IOException,
                      InterruptedException

Parameters:

fileName -

Throws:

IOException

InterruptedException

main

public static void main(String[] args)

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface IWriter