-
使用Spark执行Hudi样例程序(Python) - MapReduce服务 MRS
hudi_trips_incremental") spark.sql("select `_hoodie_commit_time`, fare, begin_lon, begin_lat, ts from hudi_trips_incremental where fare > 20.0").show() 特定时间点查询
-
开发Hive用户自定义函数 - MapReduce服务 MRS
功能介绍 AddDoublesUDF主要用来对两个及多个浮点数进行相加。在该样例中可以掌握如何编写和使用UDF。 一个普通UDF必须继承自“org.apache.hadoop.hive.ql.exec.UDF”。
-
HBase应用开发规则 - MapReduce服务 MRS
另外,有一点需要注意:HBase Client返回写入失败的数据,是不会自动重试的,仅仅会告诉接口调用者哪些数据写入失败了。对于写入失败的数据,一定要做一些安全的处理,例如可以考虑将这些失败的数据,暂时写在文件中,或者,直接缓存在内存中。
-
Spark Streaming对接Kafka0-10样例程序(Scala) - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
Spark Streaming对接Kafka0-10样例程序(Scala) - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
Spark Streaming对接Kafka0-10样例程序(Scala) - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
Spark Streaming对接Kafka0-10样例程序(Scala) - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
Storm Flux开发指引 - MapReduce服务 MRS
值为spouts中定义的kafkaSpout to: "splitBolt" #数据流终点,值为bolts中定义的splitBolt grouping:#定义分组方式 type: LOCAL_OR_SHUFFLE #分组方式为local_or_shuffle
-
Storm Flux开发指引 - MapReduce服务 MRS
值为spouts中定义的kafkaSpout to: "splitBolt" #数据流终点,值为bolts中定义的splitBolt grouping:#定义分组方式 type: LOCAL_OR_SHUFFLE #分组方式为local_or_shuffle
-
Flux开发指引 - MapReduce服务 MRS
值为spouts中定义的kafkaSpout to: "splitBolt" #数据流终点,值为bolts中定义的splitBolt grouping:#定义分组方式 type: LOCAL_OR_SHUFFLE #分组方式为local_or_shuffle
-
Scala样例代码 - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
恢复IoTDB业务数据 - MapReduce服务 MRS
“恢复点列表”:单击“刷新”,然后选择一个备集群上已备份的IoTDB目录。 在“数据配置”中的“备份数据”列根据业务需要勾选一个或多个需要恢复的已备份数据,并在“目标路径”列,指定备份数据恢复后的位置。 “目标路径”建议选择一个与目的端路径不同的新路径。
-
CREATE TABLE - MapReduce服务 MRS
GLOBAL_SORT:它提高了查询性能,特别是点查询。TBLPROPERTIES('SORT_SCOPE'='GLOBAL_SORT') LOCAL_SORT:数据会本地排序(任务级别排序)。
-
CREATE TABLE - MapReduce服务 MRS
GLOBAL_SORT:它提高了查询性能,特别是点查询。TBLPROPERTIES('SORT_SCOPE'='GLOBAL_SORT') LOCAL_SORT:数据会本地排序(任务级别排序)。 NO_SORT:默认排序。它将以不排序的方式加载数据,这将显著提升加载性能。
-
HBase全局二级索引介绍 - MapReduce服务 MRS
HBase全局二级索引支持以下重点特性: 复合索引 支持指定多个列作为索引列(支持跨列族)。 覆盖索引 支持指定多个列/列族作为覆盖列/列族冗余存储到索引表中,用于支持索引查询中对非索引列的快速查询。
-
Java样例代码 - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
Spark Streaming对接Kafka0-10样例程序(Java) - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
Spark Streaming对接Kafka0-10样例程序(Java) - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
Spark Streaming对接Kafka0-10样例程序(Java) - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。
-
Spark Streaming对接Kafka0-10样例程序(Java) - MapReduce服务 MRS
* <checkPointDir>是Spark Streaming检查点目录。