检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Data masking函数 数据脱敏(Data masking) 指对某些敏感信息通过脱敏规则进行数据的变形，实现敏感隐私数据的可靠保护。 mask_first_n(string str[, int n]) →varchar 描述：返回str的屏蔽版本，前n个值被屏蔽。大写字母
当Hive的内置函数不能满足需要时，可以通过编写用户自定义函数UDF（User-Defined Functions）插入自己的处理代码并在查询中使用它们。 按实现方式，UDF分如下分类： 普通的UDF，用于操作单个数据行，且产生一个数据行作为输出。 用户定义聚集函数UDAF（User-Defined
JDBC接口提交数据分析任务，该样例程序在“hive-examples/hive-jdbc-example”的“JDBCExample.java”中，实现该功能的模块如下： 读取HiveServer客户端property文件，其中“hiveclient.properties”文件在“hive
当Hive的内置函数不能满足需要时，可以通过编写用户自定义函数UDF（User-Defined Functions）插入自己的处理代码并在查询中使用它们。 按实现方式，UDF分为有如下分类： 普通的UDF，用于操作单个数据行，且产生一个数据行作为输出。 用户定义聚集函数UDAF（User-Defined
当Impala的内置函数不能满足需要时，可以通过编写用户自定义函数UDF（User-Defined Functions）插入自己的处理代码并在查询中使用它们。 按实现方式，UDF有如下分类： 普通的UDF，用于操作单个数据行，且产生一个数据行作为输出。 用户定义聚集函数UDAF（User-Defined
禁用HBase全局二级索引 功能简介 全局二级索引的索引状态决定了索引是否有效，通过修改索引状态，可以实现索引的禁用、启用、弃用（不再生成索引数据）等功能。通过调用“org.apache.hadoop.hbase.hindex.global.GlobalIndexAdmin”中的
使用Filter过滤器读取HBase表数据 功能简介 HBase Filter主要在Scan和Get过程中进行数据过滤，通过设置一些过滤条件来实现，如设置RowKey、列名或者列值的过滤条件。 代码样例 以下代码片段在com.huawei.bigdata.hbase.examples
禁用HBase全局二级索引 功能简介 全局二级索引的索引状态决定了索引是否有效，通过修改索引状态，可以实现索引的禁用、启用、弃用（不再生成索引数据）等功能。通过调用“org.apache.hadoop.hbase.hindex.global.GlobalIndexAdmin”中的
JDBC接口提交数据分析任务，该样例程序在“hive-examples/hive-jdbc-example”的“JDBCExample.java”中，实现该功能的模块如下： 读取HiveServer客户端property文件，其中“hiveclient.properties”文件在“hive
添加Oracle数据源 本章节适用于MRS 3.5.0及之后的版本。 HetuEngine支持配置Oracle数据源实现对Oracle数据源的接入与查询功能。本章节指导用户在集群的HSConsole界面添加Oracle类型的JDBC数据源。 前提条件 数据源与HetuEngine集群节点网络互通。
如果两辆车都通过相同序列的收费站， 通过同一收费站之间的时间差小于一个特定的值。 该例子有两种实现模式，其中实现1的逻辑如图1所示，实现2的逻辑如图2所示。 图1 实现1逻辑 实现1的逻辑说明 ： 根据车牌号聚合该车通过的所有收费站并排序，处理后数据如下： 车牌号1，[（通过时
如果两辆车都通过相同序列的收费站， 通过同一收费站之间的时间差小于一个特定的值。 该例子有两种实现模式，其中实现1的逻辑如图1所示，实现2的逻辑如图2所示。 图1 实现1逻辑 实现1的逻辑说明 ： 根据车牌号聚合该车通过的所有收费站并排序，处理后数据如下： 车牌号1，[（通过时
如果两辆车都通过相同序列的收费站， 通过同一收费站之间的时间差小于一个特定的值。 该例子有两种实现模式，其中实现1的逻辑如图1所示，实现2的逻辑如图2所示。 图1 实现1逻辑 实现1的逻辑说明 ： 根据车牌号聚合该车通过的所有收费站并排序，处理后数据如下。 车牌号1，[（通过时
本文介绍如何使用MRS集群运行Spark Streaming作业以消费Kafka数据。 假定某个业务Kafka每1秒就会收到1个单词记录。基于业务需要，开发的Spark应用程序实现实时累加计算每个单词的记录总数的功能。 Spark Streaming样例工程的数据存储在Kafka组件中，向Kafka组件发送数据。 M
ta Change事件，然后推送至Kafka中，最后由Sink Connector消费Topic中的数据并导入到大数据生态软件应用中，从而实现数据的实时入湖。 CDL服务包含了两个重要的角色：CDLConnector和CDLService。CDLConnector是具体执行数据抓
子时，使用该特性可以有效减少数据的膨胀倍数，且减少shuffle落盘的数据，从而获得性能提升。开启后，count(distinct)算子的实现，将由原来的expand+多轮聚合，变成普通的count_distinct聚合函数。 使用约束 作业已配置足够的内存。 配置参数 在Spa
创建Doris权限角色 Doris权限管理系统实现了行级别细粒度的权限控制，和基于角色的权限访问控制。 仅MRS 3.3.0及之后版本开启Kerberos认证的集群支持通过FusionInsight Manager创建角色进行赋权，如果集群为MRS 3.3.0之前的版本，无论是否
配置Spark事件队列大小 配置场景 Spark中见到的UI、EventLog、动态资源调度等功能都是通过事件传递实现的。事件有SparkListenerJobStart、SparkListenerJobEnd等，记录了每个重要的过程。 每个事件在发生后都会保存到一个队列中，Dr
地二级索引 场景介绍 为了快速对数据创建索引，HBase提供了可通过MapReduce功能创建索引的TableIndexer工具，该工具可实现添加、构建和删除索引。具体使用场景如下： 在表中预先存在大量数据的情况下，可能希望在某个列上添加索引。但是，使用addIndicesWithData()
MRS集群内节点是否支持更换网段？ 答： MRS集群内节点支持更换网段。 在集群详情页“默认生效子网”右侧单击“切换子网”。 选择当前集群所在VPC下的其他子网，即可实现可用子网IP的扩充。 新增子网不会影响当前已有节点的IP地址和子网。 父主题： 产品咨询类
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
