| Package | Description |
|---|---|
| com.xxdb | |
| com.xxdb.data | |
| com.xxdb.route | |
| com.xxdb.streaming.client | |
| com.xxdb.streaming.client.cep |
| Modifier and Type | Method and Description |
|---|---|
DBConnection |
SimpleDBConnectionPool.getConnection() |
static DBConnection |
DBConnection.internalCreateEnableReverseStreamingDBConnection(boolean asynchronousTask,
boolean useSSL,
boolean compress,
boolean usePython,
boolean isUrgent,
SqlStdEnum sqlStd) |
| Modifier and Type | Method and Description |
|---|---|
void |
DBTask.setDBConnection(DBConnection conn) |
void |
BasicDBTask.setDBConnection(DBConnection conn) |
| Constructor and Description |
|---|
BasicTableSchema(Map<Integer,Entity.DATA_TYPE> types2Index,
Map<Integer,String> name2index,
int rows,
int cols,
String tableName,
DBConnection connection) |
| Constructor and Description |
|---|
AutoFitTableAppender(String dbUrl,
String tableName,
DBConnection conn) |
AutoFitTableAppender(String dbUrl,
String tableName,
DBConnection conn,
com.xxdb.route.AutoFitTableAppender.APPEND_ACTION action) |
AutoFitTableUpsert(String dbUrl,
String tableName,
DBConnection connection,
boolean ignoreNull,
String[] pkeyColNames,
String[] psortColumns) |
| Modifier and Type | Field and Description |
|---|---|
protected LinkedBlockingQueue<DBConnection> |
AbstractClient.connList |
| Modifier and Type | Method and Description |
|---|---|
void |
StreamDeserializer.init(DBConnection conn) |
| Constructor and Description |
|---|
StreamDeserializer(Map<String,org.javatuples.Pair<String,String>> tableNames,
DBConnection conn) |
| Constructor and Description |
|---|
EventSender(DBConnection conn,
String tableName,
List<EventSchema> eventSchemas,
List<String> eventTimeKeys,
List<String> commonKeys) |
Copyright © 2024 DolphinDB. All rights reserved.