代码示例（Java） ISV Server验证所有的通知请求 ISV Server验证所有的post body通知请求 ISV Server对响应消息体进行签名 ISV Server对资源开通后的用户名和密码加密 ISV Server解密手机号和邮箱 Java代码示例（总） 父主题：

查看更多 →

Java代码样例 样例 隐私保护通话 代码样例（JAVA） 环境要求 基于JDK 1.8版本，要求JDK 1.6及以上版本。 引用库 commons-io、commons-lang3、fastjson、log4j、sun.misc.base64decoder 下载链接 点此下载 本

查看更多 →

通过控制台提交作业请参考《 数据湖探索 用户指南》中的“选择依赖资源参数说明”表说明 通过API提交作业请参考《 数据湖 探索API参考》>《创建批处理作业》中“表2-请求参数说明”关于“modules”参数的说明。 完整示例代码 通过SQL API 访问DWS表 import org.apache.spark.sql

查看更多 →

通过控制台提交作业请参考《数据湖探索用户指南》中的“选择依赖资源参数说明”表说明 通过API提交作业请参考《数据湖探索API参考》>《创建批处理作业》中“表2-请求参数说明”关于“modules”参数的说明。 完整示例代码 1 2 3 4 5 6 7 8 9 10 11

查看更多 →

'password'='######', //根据实际password修改 'driver'='com.mysql.jdbc.Driver')") 创建表参数说明请参考表1。 插入数据 1 sparkSession.sql("insert into dli_to_rds values

查看更多 →

Java样例代码 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection类： //创建一个配置类Sp

查看更多 →

参数必须设置 jssc.checkpoint("checkpoint"); // 组装Kafka的主题列表 HashSet<String> topicsSet = new HashSet<String>(Arrays.asList(topics

查看更多 →

连接前，添加“DriverManager.setLoginTimeout(n)”方法来设置超时时长，其中n表示等待服务返回的超时时长，单位为秒，类型为Int，默认为“0”（表示永不超时）。 static void executeSql(String url, ArrayList<String>

查看更多 →

通过控制台提交作业请参考《数据湖探索用户指南》中的“选择依赖资源参数说明”表说明 通过API提交作业请参考《数据湖探索API参考》>《创建批处理作业》中“表2-请求参数说明”关于“modules”参数的说明。 完整示例代码 Maven依赖 <dependency>

查看更多 →

通过控制台提交作业请参考《数据湖探索用户指南》中的“选择依赖资源参数说明”表说明 通过API提交作业请参考《数据湖探索API参考》>《创建批处理作业》中“表2-请求参数说明”关于“modules”参数的说明。 完整示例代码 通过SQL API访问 未开启Kerberos完整代码示例 1 2 3 4 5 6

查看更多 →

通过控制台提交作业请参考《数据湖探索用户指南》中的“选择依赖资源参数说明”表说明 通过API提交作业请参考《数据湖探索API参考》>《创建批处理作业》中“表2-请求参数说明”关于“modules”参数的说明。 完整示例代码 1 2 3 4 5 6 7 8 9 10 11

查看更多 →

return femaleInfo; } }); // 注册表。 DataFrame schemaFemaleInfo = sqlContext.createDataFrame(femaleInfoJavaRDD

查看更多 →

Java样例代码 功能介绍 在Spark应用中，通过使用Spark调用Hive接口来操作hive表，然后把Hive表的数据经过分析后写到HBase表。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples.SparkHivetoHbase

查看更多 →

Java样例代码 功能介绍 在Spark应用中，通过使用Streaming调用kafka接口来获取数据,然后把数据经过分析后，找到对应的HBase表记录，再写到HBase表。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

.appName("SecurityKafkaWordCount") .getOrCreate(); //创建表示来自kafka的输入行流的DataSet。 Dataset<String> lines = spark .readStream()

查看更多 →

Java代码示例（总） package com.huawei.cbc.cbcmarketplacecommentservice.ability.jsonutils; import java.io.UnsupportedEncodingException; import java

查看更多 →

通过控制台提交作业请参考《数据湖探索用户指南》中的“选择依赖资源参数说明”表说明 通过API提交作业请参考《数据湖探索API参考》>《创建批处理作业》中“表2-请求参数说明”关于“modules”参数的说明。 完整示例代码 Maven依赖 <dependency>

查看更多 →

Java样例代码 功能简介 在Spark应用中，通过使用HBase接口来实现创建表，读取表，往表中插入数据等操作。 代码样例 下面代码片段仅为演示，具体代码参见SparkOnHbaseJavaExample： 样例：创建HBase表 public class TableCreation

查看更多 →

Java样例代码 功能介绍 用户可以使用Spark调用HBase接口来操作HBase table1表，然后把table1表的数据经过分析后写到HBase table2表中。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

Streaming检查点目录。 * <brokers>是用于自举，制作人只会使用它来获取元数据 * <topics>是要消费的一个或多个kafka主题的列表 * <batchTime>是Spark Streaming批次持续时间（以秒为单位）。 */ public class SecurityKafkaWordCount

查看更多 →

MySQL分库分表迁移到DDM 方案概述 资源规划 通过DRS迁移MySQL分库分表总流程 实施步骤 父主题： 实时迁移

查看更多 →