
ALTIBASE Data Stream大体分为3个构成要素,为数据流的实时处理及分析所用的‘Data Processing & Analysis’,为数据共享及一致性保障所用的‘Data Coherency’, 为数据的实时传送所用的‘Data Delivery’。
Data Processing & Analyzing 主要功能
Data Coherency 主要功能
Data Delivery 主要功能
< ALTIBASE Data Stream 的服务方式 >
ALTIBASE Data Stream 详细功能
Data Processing & Analyzing
Stream & Event Processing
通过以DBMS类似表结构处理数据流,因此为表结构的生成、删除提供Create Topic或Drop Topic形式的操作语言,为数据流的操作提供 Insert/Select语句。
通过这种语句用户动态地生成主题(TOPIC)传送相关的数据到这个主题使得操作数据很容易。
ALTIBASE Data Stream不是单纯的数据流传送,而是为数据流的复杂处理提供强有力的概念窗口功能。
窗口是以记录数字及时间为准临时储存数据流的空间,通过这个窗口与其他TOPIC进行JOIN或窗口和窗口间的JOIN,可以实时分析其数据的特性。
CQL 功能
CQL(Continuous Query Language)是为数据处理的核心语言,使用Insert—select语句。
通过Insert-Select语句,数据流的Filtering或Transformation 或者适用以前提起的Join实时评价数据可以重新传送。
实时统计函数
CQL实时获得输入数据的统计信息(MIN, MAX, AVG, SUM 等),提供用户以实时确认的函数。
用户可以代替存储大量数据在DBMS后长时间分析,使用传送数据的同时确认现况的强劲的功能。
Data Coherency
 共享表可以由定义主键的TOPIC来生成,定义的共享表在分散环境下实时间共享节点间的数据。
例如A、B节点共享共享表C时,A或B更新C时实时反映到两边的数据,相互共享。
 共享表像通用数据库的表可以执行Insert, Update, Delete, Select。
 ALTIBASE Data Stream 为访问共享表提供ODBC和JDBC,类似访问通用数据库使用用现成的程序,
可以利用ALTIBASE Data Stream的优点。
 缓冲储存DBMS的特定表到共享表提高数十倍的性能。
 不需额外费用,数据复制及分散容易,故障后重新访问时通过网络上的其他节点的共享表恢复数据。
Data Delivery
基于表结构的数据传送
通过提供的多种数据类型,对于大部分的环境下的表结构,都不需要进行修改,可直接使用,开发者可以缩短开发时间、减少报错的可能性。例如现在ALTIBASE Data Stream像在DBMS上操作一样,定义 CHAR, VARCHAR, INTEGER, NUMERIC,
DATE, TIMESTAMP等多种数据类型,integer, float 等 primitive数据类型也可以一起传送。
实时数据传送
ALTIBASE Data Stream通过 ARTP(ALTIBASE Realtime Transfer Protocol)传送数据。
ARTP通过UDP协议传送数据,但通过ARTP不会丢失数据,快速传送数据。
正常情况下传送一个数据到其他节点时需要数微妙,传送大量数据时耗时数毫秒。
提供多种QoS
ALTIBASE Data Stream的 QoS对数据自身属性或数据处理程序上可以赋予特定功能。
例如数据库的客户端传送数据的中途由于网路异常导致传送失败时客户端要重新传送。
但在ALTIBASE Data Stream如果把其数据的QoS设为Reliable时,网路恢复的同时其数据会自动地重新传送。
ALTIBASE Data Stream提供的 QoS 类型
|
| QoS 种类 |
目的 |
适用方法 |
|
| RELIABILITY |
保障数据传送的可靠性 |
适用于任何情况也不能丢失数据的传送,为了获得最快的传送速度允许丢失部分数据,可以设置为Unreliable(Best Effort)传送模式
|
|
| HISTORY |
重传历史数据 |
访问网络的新的客户想查询现在时刻以前传送的数据时
|
|
| DURABILITY |
保障数据持久性 |
与HISTORY一起使用的QoS, 可以储存设定的内存大小的数据, 支持基于TRANSIENT Level(Shared Memory , Not Disk)的 Durability
|
|
| PRESENTATION |
保障数据的一致性 |
ALTIBASE Data Stream为保障数据一致性,用 Soft Transaction概念可以一次性把多个更新的数据组合传送或取消
|
|
| OWNERSHIP |
克服障碍,高可用性 (HA) |
HA(High Availability) 为了保证高可用性
|
|
OWNERSHIP STRENGTH |
克服障碍,高可用性 (HA) |
设置为OWNERSHIP时STRENGTH中具有最高值的客户端数据传送到用户,因此特定节点异常结束时其余节点传送的数据连续地处理以便保障高可用性
|
|
结点自动查询(Auto Discovery)和实时监控
ALTIBASE Data Stream不是通用数据库客户端、服务器模式的连接方式,而是 用附加(Attach)/分离(Detach)的连接方式来传送数据。使用这种方式可以避免一个节点故障导致整个服务故障的情况发生。
这种传送方式使ALTIBASE Data Stream 访问网络的瞬间将自己的更新信息传送到其他节点,同时也获取到其他节点的更新数据,因此可以快速的反映节点间的变化情况。这种架构的优点是可以实时监控网络的节点更新事项。
基于单点、多点传送的高效多重传送
ALTIBASE Data Stream是 基于UDP协议来传送数据的。我们也可以保证UDP协议传送数据的过程中不丢失数据,这样可以充分利用UDP协议数据传送的高效性,在多个节点间高效、快速的传送数据。
|