Flink HBase样例程序（Java） 功能介绍 通过调用Flink API读写HBase数据。 代码样例 下面列出WriteHBase和ReadHBase主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteHBase和com

查看更多 →

Flink Hudi样例程序（Java） 功能介绍 通过调用Flink API读写Hudi数据。 代码样例 下面列出WriteIntoHudi和ReadFromHudi主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoHudi和com

查看更多 →

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

查看更多 →

Java-SDK编译提示jar包冲突 问题现象 could not load a native library: netty_tcnative_osx_aarch_64 问题原因 netty-tcnative-boringssl-static版本太低。 解决方法 升级到以下版本即可解决。

查看更多 →

Flink Kafka样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入 FusionInsight 的kafka-clients-*.ja

查看更多 →

Flink HBase样例程序（Java） 功能介绍 通过调用Flink API读写HBase数据。 代码样例 下面列出WriteHBase和ReadHBase主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteHBase和com

查看更多 →

Flink Kafka样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink

查看更多 →

Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入kafka-clients-*.jar，该jar包可在client目录下获取。

查看更多 →

Spark SQL样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection： public

查看更多 →

Flink开启Checkpoint样例程序（Java） 功能介绍 假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量，并做到状态严格一致性。 代码样例 快照数据 该数据在算子制作快照时用于保存到目前为止算子记录的数据条数。 import java.io.Seriablizale;

查看更多 →

Flink开启Checkpoint样例程序（Java） 功能介绍 假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量，并做到状态严格一致性。 代码样例 快照数据 该数据在算子制作快照时用于保存到目前为止算子记录的数据条数。 import java.io.Seriablizale;

查看更多 →

编译任务 创建编译任务 在左侧菜单栏中单击“训练服务 > 编译管理”。 选择“编译任务”页签，单击“新建编译任务”，填写基本信息。 图1 新建编译任务 名称：任务组名称，只能包含数字、英文、中文、下划线、中划线，不得超过32个字符。 描述：简要描述任务信息。不得包含“@^\#$%

查看更多 →

编译任务 训练产生的模型版本，不可直接被车载芯片识别，需要经过编译工具，将训练产生的模型编译成车载芯片识别的模型。 创建编译任务 在左侧菜单栏中单击“训练服务 > 编译管理”。 选择“编译任务”页签，单击“新建编译任务”，填写基本信息。 图1 新建编译任务 名称：任务组名称，只能

查看更多 →

编译打包 操作步骤 单击小扳手，选择“设置”，进入软件包设置页面 在软件包设置页面，选择包类型为资产包，是否为全量包为全量包，其他保持默认值，单击“保存”。 单击小扳手，选择“编译”，编译软件包，成功后，关闭编译页面。 单击发布，选择发布应用到“我的仓库”。 配置发布版本号、描述

查看更多 →

国内镜像源地址 执行如下命令，利用编译器提供的脚手架设置新项目 npx asinit . 参考示例Demo完成合约文件contract.ts编写与合约SDK文件index.ts引用后，执行build命令编译AssemblyScript类型的合约文件，编译成功后在build目录下生成optimized

查看更多 →

Flink DataStream样例程序（Java） 功能介绍 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 DataStream FlinkStreamJavaExample代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.flink

查看更多 →

Flink DataStream样例程序（Java） 功能介绍 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 代码样例 下面代码片段仅为演示，完整代码参见FlinkStreamJavaExample样例工程下的com.huawei.bigdata.flink.examples

查看更多 →

functions.source.RichSourceFunction; import java.util.ArrayList; import java.util.List; import java.util.Random; // 该类是带checkpoint的source算子 public

查看更多 →

Flink DataStream样例程序（Java） 功能介绍 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 DataStream FlinkStreamJavaExample代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.flink

查看更多 →

国内镜像源地址 执行如下命令，利用编译器提供的脚手架设置新项目 npx asinit . 参考示例Demo完成合约文件contract.ts编写与合约SDK文件index.ts引用后，执行build命令编译AssemblyScript类型的合约文件，编译成功后在build目录下生成optimized

查看更多 →

编译镜像 编译镜像可以将训练模型转换为特定芯片支持的可识别的文件，编译镜像模块支持对编译镜像的增加、查询、删除以及编辑。 创建编译镜像 在左侧菜单栏中单击“训练服务 > 编译管理”。 选择“编译镜像”页签，单击“新建编译镜像”，填写基本信息。 图1 新建编译镜像 名称：包含中英文

查看更多 →