1.30.19

1.30.19.1

新增功能

  • 新增 StreamDeserializer 类,实现对异构流数据表的解析,同时,subscribe 函数新增 deserializer 参数,接收经 StreamDeserializer 解析后的数据。

  • 流订阅 subscribe 函数新增参数 userNamepassWord 支持输入登录用户名密码。

  • DBConnection.connect 支持 reconnect 参数,实现非高可用场景下,自动重连节点。

  • ExclusiveDBConnectionPool 新增支持以下参数:highAvailabilitySites, initialScript, compress, useSSL, usePython

  • DBConnection.connect 支持 usePython 参数,支持解析 python 脚本。

  • 新增 BasicTableSchema 类用于存储 BasicTable 的 rows, cols, colName, colType 等信息。

  • 在 DBConnection.run 中增加参数 tableName 参数用于在查询表时只读取表的 schema 信息而不读取整个表的数据,目前只支持内存表。

  • subscribe 函数支持批量处理订阅消息。

  • 提供分布式库并行写入接口,数据自动按分区规划通过连接池并行入库。

功能优化

  • 通过 API 连接集群服务器时,实现请求的负载均衡。

  • 改进 ExclusiveDBConnectionPool 类,实现后台并发运行多个 DBConnection。

  • MultithreadedTableWriter 对象写入内存表时,参数 dbPathtableName 的设置发生改变:dbPath 需设置为空,tableName 需为内存表表名。