-
HBase离线数据查询集群快速入门 - MapReduce服务 MRS
勾选“仅保存到如下路径”,使用默认保存路径,文件生成后将保存在集群主OMS节点的“/tmp/FusionInsight-Client”目录下。 图3 下载集群客户端提示框 单击“确定”后,等待客户端软件生成成功。
-
创建集群并执行作业 - MapReduce服务 MRS
文件可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。 OBS:以“s3a://”开头。不支持KMS加密的文件或程序。 HDFS:以“/”开头。 需要以“.sql”结尾,sql不区分大小写。 hql 否 String HQL脚本语句。
-
Spark应用开发建议 - MapReduce服务 MRS
_1) 这个过程比较耗时,尤其是数据量很大时,建议不要直接对大文件生成的RDD使用。 join() : (RDD[(K, V)], RDD[(K, W)]) => RDD[(K, (V, W))],作用是将两个RDD通过key做连接。
-
提交SQL语句 - MapReduce服务 MRS
archive_path 否 String SQL执行结果的转储文件夹。 说明: 只有select语句才会转储查询的结果。当前仅支持转储到OBS中。 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 id String SQL的执行id。
-
CarbonData表空间索引语法说明 - MapReduce服务 MRS
1575428400000,116.266922,40.179415 1575428400000,116.353706,40.156483 1575428400000,116.362699,39.942444 1575428400000,116.325378,39.963129 准备数据文件
-
HBase应用开发规则 - MapReduce服务 MRS
对于写入失败的数据,一定要做一些安全的处理,例如可以考虑将这些失败的数据,暂时写在文件中,或者,直接缓存在内存中。
-
CarbonData表空间索引语法说明 - MapReduce服务 MRS
1575428400000,116.266922,40.179415 1575428400000,116.353706,40.156483 1575428400000,116.362699,39.942444 1575428400000,116.325378,39.963129 准备数据文件
-
创建集群 - MapReduce服务 MRS
value 是 String 配置值 config_file_name 是 String 配置文件名,仅支持MRS组件配置页面上所展示的文件名。
-
Kafka流式数据处理集群快速入门 - MapReduce服务 MRS
勾选“仅保存到如下路径”,使用默认保存路径,文件生成后将保存在集群主OMS节点的“/tmp/FusionInsight-Client”目录下。 图3 下载集群客户端提示框 单击“确定”后,等待客户端软件生成成功。
-
Spark应用开发常用概念 - MapReduce服务 MRS
val file = sc.textFile("hdfs://...") val errors = file.filter(_.contains("ERROR")) errors.cache() errors.count() textFile算子从HDFS读取日志文件,返回file
-
YARN基本原理 - MapReduce服务 MRS
动态更新配置文件。MRS集群管理员可根据需要动态修改配置参数以实现在线集群管理。 Capacity Scheduler中每个队列可以限制资源使用量。队列间的资源分配以使用量作为排列依据,使得容量小的队列有竞争优势。
-
Spark REST API接口介绍 - MapReduce服务 MRS
进入解压文件夹,即“MRS_Spark_ClientConfig”,执行下列命令安装客户端 sh install.sh /opt/client 其中“/opt/client”为用户自定义路径,此处仅为举例。
-
在本地Windows环境中调测ClickHouse应用 - MapReduce服务 MRS
通过ClickHouse日志获取应用运行情况,即“logs”目录下的日志文件:clickhouse-example.log。
-
在本地Windows环境中调测ClickHouse应用(MRS 3.3.0之前版本) - MapReduce服务 MRS
通过ClickHouse日志获取应用运行情况,即logs目录下的日志文件:clickhouse-example.log。
-
在本地Windows环境中调测ClickHouse应用(MRS 3.3.0之前版本) - MapReduce服务 MRS
通过ClickHouse日志获取应用运行情况,即“logs”目录下的日志文件:clickhouse-example.log。
-
在本地Windows环境中调测ClickHouse应用 - MapReduce服务 MRS
通过ClickHouse日志获取应用运行情况,即logs目录下的日志文件:clickhouse-example.log。
-
Spark应用开发简介 - MapReduce服务 MRS
val file = sc.textFile("hdfs://...") val errors = file.filter(_.contains("ERROR")) errors.cache() errors.count() textFile算子从HDFS读取日志文件,返回file
-
Spark应用开发简介 - MapReduce服务 MRS
val file = sc.textFile("hdfs://...") val errors = file.filter(_.contains("ERROR")) errors.cache() errors.count() textFile算子从HDFS读取日志文件,返回file
-
错误码 - MapReduce服务 MRS
打开文件失败! 请尝试重新发起调用,或联系技术支持 400 12000059 Key pair xxx does not exist. 用户密钥对xxx不存在。
-
Spark应用开发简介 - MapReduce服务 MRS
val file = sc.textFile("hdfs://...") val errors = file.filter(_.contains("ERROR")) errors.cache() errors.count() textFile算子从HDFS读取日志文件,返回file