MapReduce服务 MRS-Spark输入:样例
样例
以SPARK导出到sqlserver2014数据库为例。
在sqlserver2014上创建一张空表“test_1”用于存储SparkSQL数据。执行以下语句:
create table test_1 (id int, name text, value text);
配置“Spark输入”算子,生成三个字段A、B和C:
设置了数据连接器后,单击
,系统将自动读取数据库中的字段,可根据需要选择添加,然后根据业务场景手动进行完善或者修正即可,无需逐一手动添加。
此操作会覆盖表格内已有数据。
通过“表输出”算子,将A、B和C输出到“test_1”表中:
select * from test_1;