在 Serverless SQL>SQL执行 页面编写SQL语句,单击 同步执行 或者 异步执行,执行SQL语句。例如在 tablestore20201231_benchmark01 下执行 select*from `tablestore20201231_benchmark01`.`test000` where `key`='' limit 20;
在 代码编写 页面,编写代码并验证数据是否符合预期。编写以下命令后,单击页面上方的 运行,验证 产品表数据集成 是否同步成功。SELECT*FROM dataphin_tutorial.product WHERE product_id IS NOT NULL;编写以下命令后,单击页面上方的 ...
在 代码编写 页面,编写代码并验证数据是否符合预期。编写以下命令后,单击页面上方的 运行,验证 产品表数据集成 是否同步成功。SELECT*FROM dataphin_tutorial.product WHERE product_id IS NOT NULL;编写以下命令后,单击页面上方的 ...
在 代码编写 页面,编写HADOOP_MR离线计算任务的代码。代码编写完成后,单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行...
在 代码编写 页面,编写 ARGODB_SQL 计算任务的代码。代码编写完成后,单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行配置...
在 代码编写 页面,编写 STARROCKS_SQL 计算任务的代码。代码编写完成后,单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行...
在代码开发页面编写代码。例如:echo '${sql_inputs}';echo '取上游sql节点输出第1行数据'${sql_inputs[0]};echo '取上游sql节点输出第2行数据'${sql_inputs[1]};echo '取上游sql节点输出第1行第2个字段'${sql_inputs[0][1]};echo '取上游...
您可以在资源编排控制台的资源栈或模板功能页面编写模板,ROS控制台会在您编写模板的过程中进行提示和校验。更多信息,请参见 使用ROS在线编辑器编写模板。查看资源类型详情。访问 资源类型索引,根据部署场景查看对应的资源类型。(例如:...
在 代码编写 页面,编写VIRTUAL代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行配置、资源配置。基本信息 用于定义调度任务的名称、对应责任人、描述等...
在 代码编写 页面,编写VIRTUAL代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行配置。基本信息 用于定义调度任务的名称、对应责任人、描述等基本信息。...
在 代码编写 页面,编写 INCEPTOR_SQL 计算任务的代码。检查代码。代码编写完成后,单击 预编译,系统帮助您检查编写的SQL代码的语法。单击页面上的 运行,运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数...
在 代码编写 页面,编写MapReduce离线计算任务的代码。MapReduce开发详情请参见 MapReduce。代码编写完成后,单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属 性。属性包括任务的 基本信息、参数配置、运行配置。基本...
在 代码编写 页面,编写MapReduce离线计算任务的代码。MapReduce开发详情请参见 MapReduce。代码编写完成后,单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属 性。属性包括任务的 基本信息、参数配置、运行配置。基本...
在 代码编写 页面,编写 ADB_PG_SQL 计算任务的代码。说明 编辑代码时,若需在表名或列名外使用双引号,则表名或列名仅支持小写。双引号内使用大写的项目名,则忽略引号,当做大小写不敏感处理。检查代码。代码编写完成后,单击 预编译,...
在 代码编写 页面,编写离线计算任务的IMPALA_SQL代码。检查代码。代码编写完成后,单击 预编译,系统帮助您检查编写的IMPALA_SQL代码的语法。单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本...
在 代码编写 页面,编写离线计算任务的HIVE_SQL代码。检查代码。代码编写完成后,单击 预编译,系统帮助您检查编写的HIVE_SQL代码的语法。单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息...
在 代码编写 页面,编写SHELL离线计算任务的代码。单击页面右上角的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行配置、资源配置。基本...
在 代码编写 页面,编写SHELL离线计算任务的代码。单击页面右上角的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行配置、资源配置。基本...
在代码编写页面,保存并提交SQL任务。单击页面上的 图标,保存代码。单击页面右上方的 图标,提交代码。在 提交备注 页面,填写备注信息。单击 确定并提交。说明 系统在任务提交时,解析开发环境的表和字段血缘关系;发布时,解析生产环境...
在代码编写页面,保存并提交SQL任务。单击页面上的 图标,保存代码。单击页面右上方的 图标,提交代码。在 提交备注 页面,填写备注信息。单击 确定并提交。说明 系统在任务提交时,解析开发环境的表和字段血缘关系;发布时,解析生产环境...
在 代码编写 页面,编写离线计算任务的SPARK_SQL代码。检查代码。代码编写完成后,单击 预编译,系统帮助您检查编写的SPARK_SQL代码的语法。单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本...
在代码编写页面,保存并提交SQL任务。单击页面上的 图标,保存代码。单击页面右上方的 图标,提交代码。在 提交备注 页面,填写备注信息。单击 确定并提交。后续步骤 如果您的开发模式是Dev-Prod模式,则需要发布SQL任务,详情请参见 管理...
在代码编写页面,保存并提交SQL任务。单击页面上的 图标,保存代码。单击页面右上方的 图标,提交代码。在 提交备注 页面,填写备注信息。单击 确定并提交。后续步骤 如果您的开发模式是Dev-Prod模式,则需要发布SQL任务,详情请参见 管理...
步骤三:编写并运行Shell任务代码 在代码编写页面,编写代码。在Dataphin的Linux服务器上新建目录。mkdir-p/tmp/chars/\#指定目录/tmp/chars/为python源。pip install-i ...
步骤三:编写并运行Shell任务代码 在代码编写页面,编写代码。在Dataphin的Linux服务器上新建目录。mkdir-p/tmp/chars/\#指定目录/tmp/chars/为python源。pip install-i ...
在 代码编写 页面,编写 SPARK_JAR_ON_HIVE 离线计算任务的代码。单击页面上方的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行配置、。...
在代码编写页面,按照下图操作指引,编写、预编译、格式化、运行代码。通过计算任务的方式新建目标表 在数据 开发 页面,按照下图操作指引,进入单击 计算任务 页面。在 计算任务 页面,单击 图标 后,选择 MAX_COMPUTE_SQL。在 计算任务 ...
步骤四:使用Java UDF函数 在SQL任务的代码编写页面,编写代码,例如 select java('ABCGDfagHH');单击页面右上方的 执行,查看运行结果。(可选)调度运维 如果需要定期的运行SQL任务,则需要配置SQL任务的调度参数并发布至生产环境,参与...
步骤四:使用Java UDF函数 在SQL任务的代码编写页面,编写代码,例如 select java('ABCGDfagHH');单击页面右上方的 执行,查看运行结果。(可选)调度运维 如果需要定期的运行SQL任务,则需要配置SQL任务的调度参数并发布至生产环境,参与...
在数据库SQL任务代码编写页面,编写代码。单击页面右上角的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行配置、资源配置。基本信息 用于...
在数据库SQL任务代码编写页面,编写代码。单击页面右上角的 运行,可运行代码。单击页面侧边栏 属性,配置任务 属性。属性包括任务的 基本信息、参数配置、调度属性(周期任务)、调度依赖(周期任务),运行配置、资源配置。基本信息 用于...
在 代码编写 页面,编写SPARK_JAR_ON_MAX_COMPUTE离线计算任务的代码。代码示例如下。resource_reference{"spark.py"} spark-submit-deploy-mode cluster-conf spark.hadoop.odps.task.major.version=cupid_v2-conf spark.hadoop.odps.end....
在 代码编写 页面,编写SPARK_JAR_ON_MAX_COMPUTE离线计算任务的代码。代码示例如下。resource_reference{"spark.py"} spark-submit-deploy-mode cluster-conf spark.hadoop.odps.task.major.version=cupid_v2-conf spark.hadoop.odps.end....
在代码编写页面,按照下图操作指引,编写、预编译、格式化、运行代码。通过计算任务的方式新建目标表 在数据 开发 页面,按照下图操作指引,进入单击 计算任务 页面。在 计算任务 页面,单击 图标 后,选择 MAX_COMPUTE_SQL。编写并运行...
在代码编写页面,编写并运行DataX任务的代码。代码如下。resource_reference{"datax.json"} python$DATAX_HOME/bin/datax.py datax.json#Dataphin系统已内置DataX的安装目录为DATAX_HOME/bin/datax.py。其中,resource_reference{} 用于...
在代码编写页面,编写并运行DataX任务的代码。代码如下。resource_reference{"datax.json"} python$DATAX_HOME/bin/datax.py datax.json#Dataphin系统已内置DataX的安装目录为DATAX_HOME/bin/datax.py。其中,resource_reference{} 用于...
在Python任务代码编写页面,选择需要创建的Python任务版本后,编写代码。说明 开发Python计算任务时,通常需要根据业务场景安装所需资源包。Dataphin已经预制通用资源包至系统内,您在开发代码过程中,只需要在代码开始部分添加 import ...
在Python任务代码编写页面,选择需要创建的Python任务版本后,编写代码。说明 开发Python计算任务时,通常需要根据业务场景安装所需资源包。Dataphin已经预制通用资源包至系统内,您在开发代码过程中,只需要在代码开始部分添加 import ...
步骤二:开发与预编译 FLINK_SQL 任务代码 在FLINK_SQL任务代码页面,编写任务的代码。代码如下:INSERT INTO ads_gross SELECT sku_type as prod_code,sum(sku_quantity)as sale_num FROM oms_orders GROUP BY sku_type;单击页面左上方的 ...
步骤二:开发与预编译 FLINK_SQL 任务代码 在FLINK_SQL任务代码页面,编写任务的代码。代码如下:INSERT INTO ads_gross SELECT sku_type as prod_code,sum(sku_quantity)as sale_num FROM oms_orders GROUP BY sku_type;单击页面左上方的 ...