com.xxdb.route

类 MultithreadTableWriter

java.lang.Object

com.xxdb.route.MultithreadTableWriter

public class MultithreadTableWriter
extends Object

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	MultithreadTableWriter.Status
static class	MultithreadTableWriter.ThreadStatus

构造器概要

构造器

构造器和说明
MultithreadTableWriter(String hostName, int port, String userId, String password, String dbName, String tableName, boolean useSSL, boolean highAvailability, String[] highAvailabilitySites, int batchSize, float throttle, int threadCount, String partitionedColName)

方法概要

限定符和类型	方法和说明
void	getStatus(MultithreadTableWriter.Status status)
void	getUnwrittenData(List<List<Entity>> unwrite)
boolean	insert(ErrorCodeInfo pErrorInfo, Object... args)
boolean	insert(List<List<Entity>> vectorOfVector, ErrorCodeInfo pErrorInfo)
void	waitExit()

从类继承的方法 java.lang.Object

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

构造器详细资料

MultithreadTableWriter

public MultithreadTableWriter(String hostName,
                              int port,
                              String userId,
                              String password,
                              String dbName,
                              String tableName,
                              boolean useSSL,
                              boolean highAvailability,
                              String[] highAvailabilitySites,
                              int batchSize,
                              float throttle,
                              int threadCount,
                              String partitionedColName)
                       throws Exception

抛出:

Exception

方法详细资料

getUnwrittenData

public void getUnwrittenData(List<List<Entity>> unwrite)

getStatus

public void getStatus(MultithreadTableWriter.Status status)

waitExit

public void waitExit()
              throws InterruptedException

抛出:

InterruptedException

insert

public boolean insert(List<List<Entity>> vectorOfVector,
                      ErrorCodeInfo pErrorInfo)

insert

public boolean insert(ErrorCodeInfo pErrorInfo,
                      Object... args)