public class SingleWriter extends Object implements IWriter
Modifier and Type | Field and Description |
---|---|
static String |
DELIMITER |
static org.apache.commons.logging.Log |
LOG |
static int |
TRANSACTION_LIMIT |
Constructor and Description |
---|
SingleWriter(String jdbcURL,
String user,
String pwd,
String tableName,
int txnLimit) |
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) |
public static final int TRANSACTION_LIMIT
public static final String DELIMITER
public static final org.apache.commons.logging.Log LOG
public SingleWriter(String jdbcURL, String user, String pwd, String tableName, int txnLimit) throws ConnectionException
ConnectionException
public void collectData(int colId, 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 void writeFile(FileInputStream is) throws IOException, InterruptedException
is
- IOException
InterruptedException
public void writeFile(SplitInputStream is) throws IOException, InterruptedException
is
- IOException
InterruptedException
public void writeFile(String fileName) throws IOException, InterruptedException
fileName
- IOException
InterruptedException
public static void main(String[] args)
Copyright © 2016 Actian Corporation. All Rights Reserved.