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.Mode
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, boolean enableActualSendTime)
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, boolean enableActualSendTime, boolean reconnect)
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, boolean enableActualSendTime, boolean reconnect, int tryReconnectNums)
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)
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, boolean enableActualSendTime)
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, boolean enableActualSendTime, boolean reconnect)
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, boolean enableActualSendTime, boolean reconnect, int tryReconnectNums)
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, Callback callbackHandler)
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, Callback callbackHandler, boolean enableActualSendTime)
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, Callback callbackHandler, boolean enableActualSendTime, boolean reconnect)
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, Callback callbackHandler, boolean enableActualSendTime, boolean reconnect, int tryReconnectNums)
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, MultithreadedTableWriter.Mode mode, String[] pModeOption)
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, MultithreadedTableWriter.Mode mode, String[] pModeOption, boolean enableActualSendTime)
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, MultithreadedTableWriter.Mode mode, String[] pModeOption, boolean enableActualSendTime, boolean reconnect)
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, MultithreadedTableWriter.Mode mode, String[] pModeOption, boolean enableActualSendTime, boolean reconnect, int tryReconnectNums)

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,
                                MultithreadedTableWriter.Mode mode,
                                String[] pModeOption)
                         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,
                                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

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,
                                Callback callbackHandler)
                         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,
                                int[] compressTypes,
                                MultithreadedTableWriter.Mode mode,
                                String[] pModeOption,
                                boolean enableActualSendTime)
                         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,
                                int[] compressTypes,
                                boolean enableActualSendTime)
                         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,
                                boolean enableActualSendTime)
                         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,
                                int[] compressTypes,
                                Callback callbackHandler,
                                boolean enableActualSendTime)
                         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,
                                int[] compressTypes,
                                MultithreadedTableWriter.Mode mode,
                                String[] pModeOption,
                                boolean enableActualSendTime,
                                boolean reconnect)
                         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,
                                int[] compressTypes,
                                boolean enableActualSendTime,
                                boolean reconnect)
                         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,
                                boolean enableActualSendTime,
                                boolean reconnect)
                         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,
                                int[] compressTypes,
                                Callback callbackHandler,
                                boolean enableActualSendTime,
                                boolean reconnect)
                         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,
                                int[] compressTypes,
                                MultithreadedTableWriter.Mode mode,
                                String[] pModeOption,
                                boolean enableActualSendTime,
                                boolean reconnect,
                                int tryReconnectNums)
                         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,
                                int[] compressTypes,
                                boolean enableActualSendTime,
                                boolean reconnect,
                                int tryReconnectNums)
                         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,
                                boolean enableActualSendTime,
                                boolean reconnect,
                                int tryReconnectNums)
                         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,
                                int[] compressTypes,
                                Callback callbackHandler,
                                boolean enableActualSendTime,
                                boolean reconnect,
                                int tryReconnectNums)
                         throws Exception

Throws:

Exception

Method Detail

getUnwrittenData

public List<List<Entity>> getUnwrittenData()

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)