普元数据开发平台 普元数据开发平台
产品介绍
安装部署
快速入门
操作指南
应用集成
运维指南
  • ArgoDB输入-从ArgoDB读取数据3
  • 模型
  • 开发步骤

# ArgoDB输入-从ArgoDB读取数据3

在通用配置进行变量设置,然后在组件中进行变量替换。

主要步骤如下:

  • 模型
  • 开发步骤
    • 参数配置
    • 基础配置
    • 运行结果

# 模型

input

# 开发步骤

准备数据

drop table depts;

CREATE TABLE `depts` (
`deptno` STRING,
`deptname` STRING,
`loc` STRING)
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
STORED AS HOLODESK;

INSERT INTO depts(deptno, deptname, loc )VALUES ('1', 'a1', 'loc1');
INSERT INTO depts(deptno, deptname, loc )VALUES ('2', 'a2', 'loc2');
INSERT INTO depts(deptno, deptname, loc )VALUES ('3', 'a3', 'loc3');

# 步骤1:参数配置

点击右侧通用配置,在命名参数栏进行参数添加。

input

# 步骤2:基础配置

打开关系型数据库输入组件,使用${name},(name为配置的参数)进行变量替换,替换后的sql格式:

SELECT deptno, deptname, loc FROM db_test.depts where deptno=1。

input

# 最后一步:运行结果

点击 保存-提交-运行,会将输出信息通过日志组件打印到下方。

input

← ArgoDB输入-读取ArgoDB数据2 获取文件名-读取HDFS文件名 →