public class ParallelWriter extends Object implements IWriter
Modifier and Type | Field and Description |
---|---|
static String |
DELIMITER |
TRANSACTION_LIMIT
Constructor and Description |
---|
ParallelWriter(String jdbcURL,
String user,
String pwd,
String tableName,
int jid,
int blockId,
String delim,
int txnLimit) |
public static final String DELIMITER
public ParallelWriter(String jdbcURL, String user, String pwd, String tableName, int jid, int blockId, String delim, int txnLimit) throws ConnectionException
ConnectionException
public void init() throws ConnectionException
ConnectionException
public void collectData(int colIndex, String data)
collectData
in interface IWriter
colIndex
- -- index of the columndata
- -- value of the columnpublic void writeData() throws InterruptedException
writeData
in interface IWriter
InterruptedException
public int commit() throws X100BlockException
X100BlockException
Copyright © 2016 Actian Corporation. All Rights Reserved.