Spark Structured Streaming样例程序（Java） 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：com

查看更多 →

使用Spark执行Hudi样例程序（Java） 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.hudi.examples.HoodieWriteClientExample。 创建客户端对象来操作Hudi： String tablePath = args[0];

查看更多 →

Flink Jar作业提交SQL样例程序（Java） 提交SQL的核心逻辑如下，目前只支持提交CREATE和INSERT语句。完整代码参见com.huawei.bigdata.flink.examples.FlinkSQLExecutor。 public class FlinkSQLExecutor

查看更多 →

Spark Structured Streaming样例程序（Java） 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：com

查看更多 →

通过JDBC访问Spark SQL样例程序（Java） 功能简介 使用自定义客户端的JDBC接口提交数据分析任务，并返回结果。 样例代码 定义SQL语句。SQL语句必须为单条语句，注意其中不能包含“;”。示例： ArrayList<String> sqlList = new ArrayList<String>();

查看更多 →

向量检索的客户端代码示例（Java） Elasticsearch提供了标准的REST接口，以及Java、Python等语言编写的客户端。 本节提供一份创建向量索引、导入向量数据和查询向量数据的Java代码示例，介绍如何使用客户端实现向量检索。 前提条件 根据集群实际版本添加如下Maven依赖，此处以7

查看更多 →

向量检索的客户端代码示例（Java） OpenSearch提供了标准的REST接口，以及Java、Python等语言编写的客户端。 本节提供一份创建向量索引、导入向量数据和查询向量数据的Java代码示例，介绍如何使用客户端实现向量检索。 前提条件 根据集群实际版本添加如下Maven依赖，此处以OpenSearch

查看更多 →

创建并配置客户端(Java SDK) 操作场景 本章节指导客户创建并配置客户端，该任务是使用SDK与OBS交互的必备前置任务。如果您已有客户端，请跳过该节，直接参考Java SDK接口概览(Java SDK)获取接口信息。 前提条件 初始化客户端之前，您需要先完成以下几项准备工作：

查看更多 →

Jedis客户端连接Redis（Java） 本章节介绍使用Jedis客户端连接Redis实例的方法。更多的客户端的使用方法请参考Redis客户端。 在springboot类型的项目中，spring-data-redis中已提供了对jedis、lettuce的集成适配。另外，在springboot1

查看更多 →

测试与验证 完成页面集成之后，您需要测试与验证WEB聊天控件是否能正常使用。以下以Chrome浏览器为例。在验证过程中，您可以使用Nginx 服务器 来模拟第三方调用WEB聊天控件，您也可以使用其他您熟悉的访问方式进行。 本地开启Nginx服务器（Nginx版本可参考nginx/Windows-1

查看更多 →

测试与验证 完成页面集成之后，您需要测试与验证WEB聊天控件是否能正常使用。以下以Chrome浏览器为例。在验证过程中，您可以使用Nginx服务器来模拟第三方调用WEB聊天控件，也可以使用其他您熟悉的访问方式进行。 本地开启Nginx服务器（Nginx版本可参考nginx/Windows-1

查看更多 →

可通过扫描二维码分享会议信息，进行观众邀请。 “扫码邀请”功能仅Windows客户端支持。 聊天 当主持人设置聊天模式为“允许自由聊天、仅允许公开聊天、仅允许私聊主持人”时，嘉宾进入桌面端会中界面，单击会控栏“聊天”打开右侧聊天窗口，可根据需要选择公开聊天或私聊主持人、其他嘉宾。 举手 进入桌面端会中界面，

查看更多 →

编包并运行Spark程序。 运行Python样例代码无需通过Maven打包。 将打包生成的jar包上传到Spark客户端所在服务器的任意目录（例如“ /opt/example/” ）下。 运行任务 登录Spark客户端节点，执行如下命令： source 客户端安装目录/bigdata_env

查看更多 →

。 将打包生成的jar包上传到Spark客户端所在服务器的任意目录（例如“ /opt/example/” ）下。 运行任务 登录Spark客户端节点，执行如下命令： source 客户端安装目录/bigdata_env source 客户端安装目录/Hudi/component_env

查看更多 →

通过Java客户端接入Elasticsearch集群 通过Rest High Level Client接入Elasticsearch集群 通过Rest Low Level Client接入Elasticsearch集群 通过Transport Client接入Elasticsearch集群

查看更多 →

Flink对接 云搜索服务 （ CSS ）样例程序（Java） 功能介绍 当前基于随机数生成器实现了一个持续产生长度为4字符串的数据源用于写入数据。 样例代码 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.flink.examples。 public class

查看更多 →

的默认后端服务器组。 推荐选择“使用已有”后端服务器组，您可参考创建后端服务器组进行创建。 您也可选择“新创建”后端服务器组，添加后端服务器并配置健康检查， 配置后端服务器组参数请参见表2。 单击“下一步：添加后端服务器”，添加后端服务器并配置健康检查。 添加后端服务器详见后端服务器概述，配置健康检查参数请参见表3。

查看更多 →

Redisson客户端连接Redis（Java） 本章节介绍使用Redisson客户端连接Redis实例的方法。更多的客户端的使用方法请参考Redis客户端。 在springboot类型的项目中，spring-data-redis中提供了对jedis、lettuce的适配，但没有

查看更多 →

FlinkServer REST API样例程序（Java） 功能介绍 通过调用FlinkServer RestAPI创建租户。 代码样例 具体代码参见com.huawei.bigdata.flink.examples.TestCreateTenants。 public class

查看更多 →

单击“查看详情”可了解与会者更多网络详情。 开启会中聊天 网络研讨会中支持文字聊天，主持人可根据会议场景设置聊天模式。 进入桌面端会中界面，单击会控栏中“聊天”打开聊天界面。 单击消息输入框右上角的下拉菜单，可根据需要设置会中聊天模式。 允许自由聊天：嘉宾可以私聊主持人/其他嘉宾或公开发送聊天消息；观众可以私聊主持人或公开发送聊天消息。

查看更多 →

数据共享：支持桌面屏幕共享（多个屏幕时，可选择任一屏幕进行共享），程序共享和白板共享。程序可以是计算机中的PowerPoint文档、音视频文件及其他可在桌面显示的内容，或者正在运行的某个应用程序界面。 白板标注：支持协同标注，观看共享桌面/白板/程序时，可进行标注，实时双向互动。 远程协助：支持远

查看更多 →