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;
- MapReduce服务_什么是MapReduce服务_什么是HBase
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用
- MapReduce服务_什么是Hue_如何使用Hue
- MapReduce服务_什么是HetuEngine_如何使用HetuEngine
- MapReduce服务_什么是Kafka_如何使用Kafka
- 语音识别python_文字语音识别_电脑语音识别输入法
- MapReduce服务_什么是ZooKeeper_如何使用ZooKeeper
- MapReduce服务_什么是ClickHouse_如何使用ClickHouse
- MapReduce服务_什么是HDFS_HDFS特性
- MapReduce服务_什么是Yarn_如何使用Yarn