开发者学习中心

开发者一站式学习、体验中心,学有所得、学有所乐!

 

    Java单例模式 更多内容
  • Java样例代码

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

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能介绍 在Spark应用中,通过使用Spark调用Hive接口来操作hive表,然后把Hive表的数据经过分析后写到HBase表。 代码样 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.spark.examples.SparkHivetoHbase

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能介绍 在Spark应用中,通过使用StructuredStreaming调用Kafka接口来获取单词记录,然后把单词记录分类统计,得到每个单词记录数。 代码样 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.spark.examples

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.hudi.examples.HoodieWriteClientExample 创建客户端对象来操作Hudi: String tablePath = args[0]; String tableName

    来自:帮助中心

    查看更多 →

  • Java样例代码

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

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能介绍 假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量,并做到状态严格一致性。 代码样 快照数据 该数据在算子制作快照时用于保存到目前为止算子记录的数据条数。 import java.io.Seriablizale; // 该类作为快照的一部分,保存用户自定义状态

    来自:帮助中心

    查看更多 →

  • Java样例代码

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

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 下面代码片段仅为演示,具体代码参见:com.huawei.spark.examples.HBaseExternalHivetoCarbon。 public static void main(String[] args) throws Exception { spark

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.hudi.examples.HoodieWriteClientExample 创建客户端对象来操作Hudi: String tablePath = args[0]; String tableName

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能介绍 当前基于随机数生成器实现了一个持续产生长度为4字符串的数据源用于写入数据。 样代码 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.flink.examples。 public class FlinkEsSinkExample

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能介绍 假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量,并做到状态严格一致性。 代码样 快照数据 该数据在算子制作快照时用于保存到目前为止算子记录的数据条数。 import java.io.Seriablizale; // 该类作为快照的一部分,保存用户自定义状态

    来自:帮助中心

    查看更多 →

  • Java样例代码

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

    来自:帮助中心

    查看更多 →

  • Java样例代码

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

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样 下面代码片段仅为演示,具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection类: //创建一个配置类Sp

    来自:帮助中心

    查看更多 →

  • Java样例代码

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

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能介绍 用户可以使用Spark调用HBase接口来操作HBase table1表,然后把table1表的数据经过分析后写到HBase table2表中。 代码样 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.spark.examples

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.hudi.examples.HoodieWriteClientExample。 创建客户端对象来操作Hudi: String tablePath = args[0]; String tableName

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能简介 通过JDBC连接方式,执行IoTDB SQL语句。 代码样 下面代码片段仅为演示,具体代码参见“com.huawei.bigdata.iotdb.JDBCExample”类。 其中,在jdbc url里设置待连接的IoTDBServer所在的节点IP、端口、用户名和密码。

    来自:帮助中心

    查看更多 →

  • Java样例代码

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

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 代码样 假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量,并做到状态严格一致性。 快照数据 该数据在算子制作快照时,用于保存到目前为止算子记录的数据条数。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 import

    来自:帮助中心

    查看更多 →

  • Java样例代码

    Java代码 功能简介 在Flink应用中,调用flink-connector-kafka模块的接口,生产并消费数据。 用户在开发前需要使用对接安全模式的Kafka,则需要引入 MRS 的kafka-client-xx.x.x.jar,该jar包可在MRS client目录下获取。

    来自:帮助中心

    查看更多 →

共105条
看了本文的人还看了