gbase数据、南大通用产品文档：GBase8aDataAdapter 属性

获取或设置一个用于自动生成SQL 语句的GBaseDataAdapter 对象。

语法
[Visual Basic]
Public Property DataAdapter As GBaseDataAdapter

Get

GBase 8a 程序员手册ADO.NET 篇


- 152 -

南大通用数据技术股份有限公司

Set
[C#]
public GBaseDataAdapter DataAdapter { get; set; }

属性
一个GBaseDataAdapter 对象。

注释
GBaseCommandBuilder把自己作为一个监听器注册到RowUpdating 事件上，
该事件由属性上指定的GBaseDataAdapter 产生。

取值：NameNode 列表
默认值：无
说明：用于指定HDFS 高可用NameNode 列表，通过此参数可指定两个NameNode
的host（即主机名或IP 地址），两个host 之间用英文逗号分隔，每个host 后可跟
“:port”形式的端口号。
如果有多套HDFS 环境，两套HDFS 的高可用NameNode 组之间使用'|'分隔。
示例：
gbase_hdfs_namenodes ='hdp-nn1:50070,hdp-nn2:50070'
gbase_hdfs_namenodes =' hdp-nn1:50070,hdp-nn2:50070|
hdp-nn3:50070,hdp-nn4:50070'。
修改方式：全局参数，在配置文件中赋值和修改。

数据同步系统通过Oracle Golden Gate（OGG）、GBase RTSync 等工具复制
Oracle、
GBase 8s 等数据库的业务数据，
通过kafka 同步到GBase 8a MPP Cluster，

GBase 8a MPP Cluster 技术白皮书


- 20 -

南大通用数据技术股份有限公司
为了应对业务系统可能的峰值，在系统中加入Kafka 消息队列作为缓冲区。总
体流程如下：

图 4-1 处理流程
OGG 发送端（GoldenGate
Extract）从Oracle 的在线日志和归档日志中抽
取事务信息，
生成Trail 文件。
OGG 接收端
（GoldenGate
Replicat）
收到Trail
文件抽取事务信息转换为目标格式，并生产事务消息到Kafka。Consumer 从
Kafka 中消费事务消息，将数据更新到8a MPP Cluster 中。
Kafka consumer 的主要功能就是同步Kafka 数据到8a MPP Cluster：
1） 根据配置，可以指定需要同步的业务；
2） 在同步过程中，提供同步状态查询功能；
3） 实现数据同步的高可用性和事务数据一致性。
虚拟集群及镜像集群