检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
具体版本信息请以实际情况为准。 应用开发操作步骤 确认Storm和HBase组件已经安装，并正常运行。 将storm-examples导入到IntelliJ IDEA开发环境，请参见准备Storm应用开发环境。 下载并安装HBase客户端。 获取相关配置文件。获取方法如下： 在安
Java样例代码 功能介绍 实时统计连续网购时间超过半个小时的女性网民信息，将统计结果直接打印或者输出写入到Kafka中。 Spark Streaming Write To Print代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples
除了这一步外还需要将$SPARK_HOME/jars/streamingClient010目录中的kafka-clients jar包复制到$SPARK_HOME/jars目录下，否则会报class not found异常。 进入Spark客户端目录，调用bin/spark-su
据业务需要，勾选“读”（SELECT权限）或者“写”（INSERT权限）权限，单击“确定”。 添加用户并将ClickHouse对应角色绑定到该用户 登录Manager，选择“系统 > 权限 > 用户”，单击“添加用户”，进入添加用户页面。 “用户类型”选择“人机”，在“密码”和“确认密码”参数设置该用户对应的密码。
在Manager界面选择“集群 > 服务 > HDFS > 更多 > 下载客户端”，将客户端中的core-site.xml和hdfs-site.xml复制到样例工程的conf目录下，并对hdfs-site.xml添加以下内容： <property> <name>dfs.client.use.datanode
在Manager界面选择“集群 > 服务 > HDFS > 更多 > 下载客户端”，将客户端中的core-site.xml和hdfs-site.xml复制到样例工程的conf目录下，并对hdfs-site.xml添加以下内容： <property> <name>dfs.client.use.datanode
除了这一步外还需要将$SPARK_HOME/jars/streamingClient010目录中的kafka-clients jar包复制到$SPARK_HOME/jars目录下，否则会报class not found异常。 进入Spark客户端目录，调用bin/spark-su
Manager，在“主页”右上方单击“下载客户端”，“选择客户端类型”设置为“仅配置文件”，单击“确定”，等待客户端文件包生成后根据浏览器提示下载客户端到本地并解压。 例如，客户端配置文件压缩包为“FusionInsight_Cluster_1_Services_Client.tar”，解压后
点类型选择正确的平台类型后（x86选择x86_64，ARM选择aarch64）单击“确定”，等待客户端文件包生成后根据浏览器提示下载客户端到本地并解压。 例如，客户端文件压缩包为“FusionInsight_Cluster_1_Services_Client.tar”，解压后得到
> 服务 > Hive > 更多 > 下载客户端”，将客户端中的core-site.xml和hiveclient.properties复制到样例工程的resources目录下。 修改样例代码中的JDBC URL中使用zookeeper的连接改为直接使用hiveserver2的地址
在Manager界面选择“集群 > 服务 > HDFS > 更多 > 下载客户端”，将客户端中的core-site.xml和hdfs-site.xml复制到样例工程的conf目录下。 对hdfs-site.xml添加如下内容： <property> <name>dfs.client
*参数从HDFS获取到的值，如果为主机名，需要修改为该主机名对应的业务IP。 配置clickhouse-to-hdfs-customize自定义参数时，涉及到nameservice必须使用小写（无论HDFS集群的nameservice是否大写），例如hdfs集群的nameservice为NS1，则
登录集群的FusionInsight Manager，选择“集群 > 服务 > Kafka > 更多 > 下载客户端”，下载客户端压缩文件到本地机器。 使用客户端根目录中的“ca.crt”证书文件生成客户端的“truststore”。 执行命令如下： keytool -noprompt
在Manager界面选择“集群 > 服务 > Spark2x > 更多 > 下载客户端”，将客户端中的core-site.xml和hdfs-site.xml复制到样例工程的conf目录下。 对hdfs-site.xml添加如下内容： <property> <name>dfs.client
> 服务 > Hive > 更多 > 下载客户端”，将客户端中的core-site.xml和hiveclient.properties复制到样例工程的resources目录下。 修改样例代码中的JDBC URL中使用ZooKeeper的连接改为直接使用HiveServer2的地址
因此推荐使用keytab方式。 应用开发操作步骤 确认Storm和HBase组件已经安装，并正常运行。 将storm-examples导入到Eclipse开发环境，请参见导入并配置Storm样例工程。 如果集群启用了安全服务，按登录方式分为以下两种。 keytab方式：需要从管理
completed successfully in 36 sec 将2中生成的Jar包（如FlinkStreamJavaExample.jar）复制到Flink客户端节点相关目录下，例如“/opt/client”。然后在该目录下创建“conf”目录，将需要的配置文件复制至“conf”目录，
> 服务 > Hive > 更多 > 下载客户端”，将客户端中的core-site.xml和hiveclient.properties复制到样例工程的resources目录下。 修改样例代码中的JDBC URL中使用zookeeper的连接改为直接使用hiveserver2的地址
登录集群的FusionInsight Manager，选择“集群 > 待操作的集群名称 > 服务 > Kafka > 更多 > 下载客户端”，下载客户端压缩文件到本地机器。 使用客户端根目录中的“ca.crt”证书文件生成客户端的“truststore”。 执行命令如下： keytool -noprompt
据业务需要，勾选“读”（SELECT权限）或者“写”（INSERT权限）权限，单击“确定”。 添加用户并将ClickHouse对应角色绑定到该用户 登录Manager，选择“系统 > 权限 > 用户”，单击“添加用户”，进入添加用户页面。 “用户类型”选择“人机”，在“密码”和“确认密码”参数设置该用户对应的密码。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
