检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
通过Windows系统提交MapReduce任务 配置场景 用户将MapReduce任务从Windows上提交到Linux上运行，则“mapreduce.app-submission.cross-platform”参数值需配置为“true”。
MRS集群内节点的操作系统是什么？ 问： MRS集群内节点的操作系统是什么？ 答： 不同版本的集群对应的主机操作系统不同，具体对应关系如表1所示。
基于Kafka的Word Count数据流统计案例 应用场景 Kafka是一个分布式的消息发布-订阅系统。它采用独特的设计提供了类似JMS的特性，主要用于处理活跃的流式数据。
通过Flume采集指定目录日志系统文件至HDFS 应用场景 Flume是一个分布式、可靠和高可用的海量日志聚合的系统。它能够将不同数据源的海量日志数据进行高效收集、聚合、移动，最后存储到一个中心化数据存储系统中。支持在系统中定制各类数据发送方，用于收集数据。
oozieClient.getJobInfo(jobId))); } /** * Get job.properties File in filePath * * @param filePath file path * @return
举例如下： select i_item_id item_id, sum(sr_return_quantity) sr_item_qty from store_returns, item, date_dim where sr_item_sk
举例如下： select i_item_id item_id, sum(sr_return_quantity) sr_item_qty from store_returns, item, date_dim where sr_item_sk
create timeseries root.company.line1.device2.power WITH DATATYPE=FLOAT, ENCODING=RLE; create timeseries root.company.line2.device1.temperature
程序 通过JDBC访问Spark SQL的程序 Spark on HBase程序 从HBase读取数据再写入HBase 从Hive读取数据再写入HBase Streaming从Kafka读取数据再写入HBase Spark Streaming对接kafka0-10程序 Structured
图2 Configure 在“Project Defaults”页面中，选择“Project Structure”。 图3 Project Defaults 在打开的“Project Structure”页面中，选择“SDKs”，单击绿色加号添加JDK。
oozieClient.getJobInfo(jobId))); } /** * Get job.properties File in filePath * * @param filePath file path * @return
ImmutableList.of(new SubQuery("city.temp", "sum"), new SubQuery("city.hum", "sum")); query.delete = true; Gson gson = new Gson(); return
在IDEA主页，选择“File > Project Structures...”进入“Project Structure”页面。 选择“Modules”，选中工程名称，然后右键选择“Add > Scala”。
Finished processing dependencies for future==0.18.2 父主题： 准备Spark应用开发环境
Finished processing dependencies for future==0.18.2 父主题： 准备Spark应用开发环境
ClickHouse系统表日志过大时如何添加定期删除策略？ 问题现象 客户使用ClickHouse，系统表产生的日志过大，一次性删除会耗费较长时间，客户可以添加定期删除策略，即添加TTL。
spark-shell执行SQL跨文件系统load数据到Hive表失败 用户问题 使用spark-shell命令执行SQL或者spark-submit提交的Spark任务里面有SQL的load命令，并且原数据和目标表存储位置不是同一套文件系统，上述两种方式MapReduce任务启动时会报错
Finished processing dependencies for future==0.18.2 父主题： 准备Spark应用开发环境
columns // If returned columns not included in index table, will query back user table, // it's not the fast way to get data, suggest
Finished processing dependencies for future==0.18.2 父主题： 准备Spark应用开发环境
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
