-
Java开发环境配置
![]()
Files\Java\jdk1.8.0_131”。 配置Java环境变量：右键“计算机 >属性 >高级系统设置 >环境变量”，进行如下操作。 新建系统变量JAVA_HOME，变量值为实际JDK安装位置。 在Path中添加“%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin” （注意用英文分号分隔）。
来自：帮助中心 -
镜像部署Java Web环境
-
主机上没有安装java环境
![]()
主机上没有安装java环境 问题现象 日志提示如下图所示信息。 图1 日志信息 原因分析 出现上述日志信息属于正常报错，由于主机上没有安装java环境，在使用java-version进行检测时找不到java命令导致的报错，此现象不影响应用执行。 处理方法 请参考安装JDK。 父主题：
来自：帮助中心 -
Flink DataStream样例程序（Java）
![]()
Flink DataStream样例程序（Java） 功能介绍 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 DataStream FlinkStreamJavaExample代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.flink
来自：帮助中心 -
Flink DataStream样例程序（Java）
![]()
Flink DataStream样例程序（Java） 功能介绍 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 代码样例 下面代码片段仅为演示，完整代码参见FlinkStreamJavaExample样例工程下的com.huawei.bigdata.flink.examples
来自：帮助中心 -
Flink开启Checkpoint样例程序（Java）
![]()
functions.source.RichSourceFunction; import java.util.ArrayList; import java.util.List; import java.util.Random; // 该类是带checkpoint的source算子 public
来自：帮助中心 -
Flink DataStream样例程序（Java）
![]()
Flink DataStream样例程序（Java） 功能介绍 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 DataStream FlinkStreamJavaExample代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.flink
来自：帮助中心 -
Flink Kafka样例程序（Java）
![]()
Flink Kafka样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入 FusionInsight 的kafka-clients-*.ja
来自：帮助中心 -
Flink HBase样例程序（Java）
![]()
Flink HBase样例程序（Java） 功能介绍 通过调用Flink API读写HBase数据。 代码样例 下面列出WriteHBase和ReadHBase主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteHBase和com
来自：帮助中心 -
Spark SQL样例程序（Java）
![]()
Spark SQL样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection： public
来自：帮助中心 -
Flink Kafka样例程序（Java）
![]()
Flink Kafka样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink
来自：帮助中心 -
Flink Join样例程序（Java）
![]()
Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入kafka-clients-*.jar，该jar包可在client目录下获取。
来自：帮助中心 -
Spark SQL样例程序（Java）
![]()
Spark SQL样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection： public
来自：帮助中心 -
Flink Kafka样例程序（Java）
![]()
Flink Kafka样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink
来自：帮助中心 -
Flink Join样例程序（Java）
![]()
Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入kafka-clients-*.jar，该jar包可在client目录下获取。
来自：帮助中心 -
Spark SQL样例程序（Java）
![]()
Spark SQL样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection： public
来自：帮助中心 -
Spark Core样例程序（Java）
![]()
Spark Core样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection类：
来自：帮助中心 -
Flink Join样例程序（Java）
![]()
Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入FusionInsight的kafka-clients-*.jar
来自：帮助中心 -
Flink Hudi样例程序（Java）
![]()
Flink Hudi样例程序（Java） 功能介绍 通过调用Flink API读写Hudi数据。 代码样例 下面列出WriteIntoHudi和ReadFromHudi主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoHudi和com
来自：帮助中心 -
准备Spark应用Java开发环境
![]()
准备Spark应用Java开发环境 操作场景 Java开发环境可以搭建在Windows环境下，而运行环境（即客户端）只能部署在Linux环境下。 操作步骤 对于Java开发环境，推荐使用IDEA工具，安装要求如下。 JDK使用1.7版本（或1.8版本） IntelliJ IDEA（版本：13
来自：帮助中心 -
Flink DataStream样例程序（Java）
![]()
Flink DataStream样例程序（Java） 功能介绍 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 DataStream FlinkStreamJavaExample代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.flink
来自：帮助中心
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
