public class MultithreadTableWriter extends Object
| 限定符和类型 | 类和说明 |
|---|---|
class |
MultithreadTableWriter.ErrorCodeInfo |
| 构造器和说明 |
|---|
MultithreadTableWriter(String hostName,
int port,
String userId,
String password,
String dbName,
String tableName,
boolean useSSL,
int batchSize,
float throttle,
int threadCount,
String threadByColName) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
getUnwrittenData(List<List<AbstractEntity>> unwrite) |
boolean |
insertValue(MultithreadTableWriter.ErrorCodeInfo pErrorInfo,
Object... args) |
boolean |
insertVector(List<List<AbstractEntity>> vectorOfVector,
MultithreadTableWriter.ErrorCodeInfo pErrorInfo) |
public void getUnwrittenData(List<List<AbstractEntity>> unwrite)
public boolean insertVector(List<List<AbstractEntity>> vectorOfVector, MultithreadTableWriter.ErrorCodeInfo pErrorInfo)
public boolean insertValue(MultithreadTableWriter.ErrorCodeInfo pErrorInfo, Object... args)
Copyright © 2022 DolphinDB. All rights reserved.