pHead里面的Header name。 将Header name都改为小写，即调用lowerCase()函数，SignerUtils工具类请参考1，参考如下： private Map<String, String> lowerCaseSignedHeaders(Map<String

查看更多 →

MapReduce的安全认证代码 目前使用统一调用LoginUtil类进行安全认证。 在MapReduce样例工程的“com.huawei.bigdata.mapreduce.examples”包的“FemaleInfoCollector”类的代码中，test@<系统 域名 >、user.keytab和krb5

查看更多 →

WordCountDemo类的createWordCountStream方法中。 static void createWordCountStream(final StreamsBuilder builder) { // 从 input-topic 接收输入记录 final KStream<String

查看更多 →

MapReduce的安全认证代码 目前使用统一调用LoginUtil类进行安全认证。 在MapReduce样例工程的“com.huawei.bigdata.mapreduce.examples”包的“FemaleInfoCollector”类的代码中，test@<系统域名>、user.keytab和krb5

查看更多 →

下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection类： //创建一个配置类SparkConf，然后创建一个SparkContext SparkSession spark = SparkSession

查看更多 →

下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection类： //创建一个配置类SparkConf，然后创建一个SparkContext SparkSession spark = SparkSession

查看更多 →

下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection类： //创建一个配置类SparkConf，然后创建一个SparkContext SparkSession spark = SparkSession

查看更多 →

对象的生命中的满足一定条件，执行一定操作，或者等待某事件的条件或者情况。 StateMachine 状态机是展示状态与状态转换的图。通常一个状态机依附于一个类，并且描述一个类的实例对接收到的事件所发生的反应。 Fork Join (Fork)复杂转换中，一个源状态可以转入多个目标状态，使活动状态的数目增加。

查看更多 →

下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection类： //创建一个配置类SparkConf，然后创建一个SparkContext SparkSession spark = SparkSession

查看更多 →

删除中间人 通过此重构，您可以将对类中的委托方法的调用替换为直接对委托字段的等效调用。您还可以删除委托方法，这些方法在重构后将不再使用。 执行重构 在代码编辑器中，将光标放置在其声明中委托字段的名称上。 在主菜单或编辑器上下文菜单中，选择Refactor>Remove Middleman。

查看更多 →

huawei.bigdata.spark.examples.FemaleInfoCollection类。 样例代码获取方式请参考获取 MRS 应用开发样例工程。 代码样例： //创建一个配置类SparkConf，然后创建一个SparkContext SparkConf conf

查看更多 →

如下是删除文件的代码片段，详细代码请参考com.huawei.bigdata.hdfs.examples中的HdfsExample类。 // 业务示例2：多线程 final int THREAD_COUNT = 2; for (int threadNum = 0; threadNum < THREAD_COUNT;

查看更多 →

如下是删除文件的代码片段，详细代码请参考com.huawei.bigdata.hdfs.examples中的HdfsExample类。 // 业务示例2：多线程 final int THREAD_COUNT = 2; for (int threadNum = 0; threadNum < THREAD_COUNT;

查看更多 →

应用开发类 java sdk引用spring框架，显示“could not load a native library: netty_tcnative_osx_aarch_64”，jdk版本为64bit、1.8，部署包选择依赖时请选取最高版本。 <dependency>

查看更多 →

代码样例 以下代码片段仅为演示，具体代码参见“com.huawei.bigdata.iotdb.SessionbyKerberosExample”类。 在Manager界面，选择“集群 > 服务 > IoTDB > 实例”，查看待连接的IoTDBServer所在的节点IP。 RPC端口可通过登录 FusionInsight

查看更多 →

如下是删除文件的代码片段，详细代码请参考com.huawei.bigdata.hdfs.examples中的HdfsExample类。 // 业务示例2：多线程 final int THREAD_COUNT = 2; for (int threadNum = 0; threadNum < THREAD_COUNT;

查看更多 →

如下是删除文件的代码片段，详细代码请参考com.huawei.bigdata.hdfs.examples中的HdfsExample类。 // 业务示例2：多线程 final int THREAD_COUNT = 2; for (int threadNum = 0; threadNum < THREAD_COUNT;

查看更多 →

"" ------- } 3、x-imports 作用： 自主定义类中需要添加的 import 引用。 标签值类型： List 使用位置： x-imports（当定义在swagger的最外层时，所有的类中都会引入import） components.schemas.model

查看更多 →

Connect实例控制台的“设备集成 LINK > 设备管理”页面中，单击对应设备的名称，在设备详情页面获取。 重新编译并运行DeviceControlDemo这个类，如果此时该设备处于连接状态并订阅了sub权限的Topic，设备会立即收到一条消息，并在IDE控制台打印出来。API的请求IP和设备连接的IP是相同的，端口是7443。

查看更多 →

组件业务用户 代码认证 通过获取客户端的principal和keytab文件在应用程序中进行认证。 安全认证代码 目前是统一调用LoginUtil类进行安全认证。 在MapReduce样例工程代码中，test@HADOOP.COM、user.keytab和krb5.conf为示例，实际操

查看更多 →

开发自定义鉴权插件 devspore提供鉴权插件接口，您只需实现对应鉴权接口即可。 自定义鉴权插件 继承抽象类Processor，实现doProcess接口，可定义多个插件。 插件均需注册为bean。 import com.huawei.devspore.plugin.spi.authorization

查看更多 →