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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

如下是删除文件的代码片段，详细代码请参考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;

查看更多 →

如下是删除文件的代码片段，详细代码请参考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;

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

tatic</artifactId> <version>2.0.44.Final</version> </dependency> 父主题： 接口类问题

查看更多 →

/sysconfig/network-scripts/ifcfg-ethX”，注释HWADDR这一项。 父主题： Cloud-Init操作类

查看更多 →