com.xxdb.multithreadedtablewriter

Class MultithreadedTableWriter

java.lang.Object

com.xxdb.multithreadedtablewriter.MultithreadedTableWriter

public class MultithreadedTableWriter
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MultithreadedTableWriter.Status
static class	MultithreadedTableWriter.ThreadStatus

Constructor Summary

Constructors

Constructor and Description
MultithreadedTableWriter(String hostName, int port, String userId, String password, String dbName, String tableName, boolean useSSL, boolean enableHighAvailability, String[] highAvailabilitySites, int batchSize, float throttle, int threadCount, String partitionCol)
MultithreadedTableWriter(String hostName, int port, String userId, String password, String dbName, String tableName, boolean useSSL, boolean enableHighAvailability, String[] highAvailabilitySites, int batchSize, float throttle, int threadCount, String partitionCol, int[] compressTypes)

Method Summary

Modifier and Type	Method and Description
List<List<Entity>>	getFailedData()
MultithreadedTableWriter.Status	getStatus()
List<List<Entity>>	getUnwrittenData()
ErrorCodeInfo	insert(Object... args)
ErrorCodeInfo	insertUnwrittenData(List<List<Entity>> records)
void	waitForThreadCompletion()

Methods inherited from class java.lang.Object

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

Constructor Detail

MultithreadedTableWriter

public MultithreadedTableWriter(String hostName,
                                int port,
                                String userId,
                                String password,
                                String dbName,
                                String tableName,
                                boolean useSSL,
                                boolean enableHighAvailability,
                                String[] highAvailabilitySites,
                                int batchSize,
                                float throttle,
                                int threadCount,
                                String partitionCol,
                                int[] compressTypes)
                         throws Exception

Throws:

Exception

MultithreadedTableWriter

public MultithreadedTableWriter(String hostName,
                                int port,
                                String userId,
                                String password,
                                String dbName,
                                String tableName,
                                boolean useSSL,
                                boolean enableHighAvailability,
                                String[] highAvailabilitySites,
                                int batchSize,
                                float throttle,
                                int threadCount,
                                String partitionCol)
                         throws Exception

Throws:

Exception

Method Detail

getUnwrittenData

public List<List<Entity>> getUnwrittenData()
                                    throws InterruptedException

Throws:

InterruptedException

getFailedData

public List<List<Entity>> getFailedData()
                                 throws InterruptedException

Throws:

InterruptedException

getStatus

public MultithreadedTableWriter.Status getStatus()

waitForThreadCompletion

public void waitForThreadCompletion()
                             throws InterruptedException

Throws:

InterruptedException

insertUnwrittenData

public ErrorCodeInfo insertUnwrittenData(List<List<Entity>> records)

insert

public ErrorCodeInfo insert(Object... args)