1.30.19
1.30.19.1
新增功能
-
新增
StreamDeserializer
类,实现对异构流数据表的解析,同时,subscribe
函数新增 deserializer 参数,接收经StreamDeserializer
解析后的数据。 -
流订阅
subscribe
函数新增参数 userName 和 passWord 支持输入登录用户名密码。 -
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
对象写入内存表时,参数 dbPath 和 tableName 的设置发生改变:dbPath 需设置为空,tableName 需为内存表表名。