搜索结果
查询Tags标签： Streaming，共有 37条记录-
Flink流处理-Task之OnlineStatisticsTask
OnlineStatisticsTask package pers.aishuang.flink.streaming.task; import org.apache.commons.lang.StringUtils; import org.apache.flink.api.common.serialization.SimpleStringSchema; import org.apache.flink.streaming.api.datastream.*; import org.apache.fli…
2021/11/8 6:12:30 人评论 次浏览 -
Flink流处理-Task之KafkaSourceDataTask
KafkaSourceDataTask package pers.aishuang.flink.streaming.task; import org.apache.flink.api.common.functions.MapFunction; import org.apache.flink.api.common.serialization.SimpleStringSchema; import org.apache.flink.streaming.api.datastream.DataStream;…
2021/11/8 6:12:29 人评论 次浏览 -
Flink流处理-Task之KafkaSourceDataTask
KafkaSourceDataTask package pers.aishuang.flink.streaming.task; import org.apache.flink.api.common.functions.MapFunction; import org.apache.flink.api.common.serialization.SimpleStringSchema; import org.apache.flink.streaming.api.datastream.DataStream;…
2021/11/8 6:12:29 人评论 次浏览 -
9次Java面试经验总结，图文详解！
一、对Kafka的认识 1.Kafka的基本概念 2.安装与配置 3.生产与消费 4.服务端参数配置二、生产者 1.客户端开发 2.原理分析 3.重要的生产者参数三、消费者 1.消费者与消费组 2.客户端开发四、主题与分区 1.主题的管理 2.初识KafkaAdminCilent 3.分区的管理 4.如何选择合适的…
2021/7/14 17:07:28 人评论 次浏览 -
9次Java面试经验总结，图文详解！
一、对Kafka的认识 1.Kafka的基本概念 2.安装与配置 3.生产与消费 4.服务端参数配置二、生产者 1.客户端开发 2.原理分析 3.重要的生产者参数三、消费者 1.消费者与消费组 2.客户端开发四、主题与分区 1.主题的管理 2.初识KafkaAdminCilent 3.分区的管理 4.如何选择合适的…
2021/7/14 17:07:28 人评论 次浏览 -
Java面试总结，复盘上次Redis缓存雪崩事故
一、对Kafka的认识 1.Kafka的基本概念2.安装与配置3.生产与消费4.服务端参数配置二、生产者 1.客户端开发 必要的参数配置消息的发送序列化分区器生产者拦截器2.原理分析 整体架构元数据的更新3.重要的生产者参数三、消费者 1.消费者与消费组2.客户端开发 必要的参数配置订…
2021/7/9 2:07:19 人评论 次浏览 -
Flink实战(八) - Streaming Connectors 编程
1 概览 1.1 预定义的源和接收器 Flink内置了一些基本数据源和接收器，并且始终可用。该预定义的数据源包括文件，目录和插socket，并从集合和迭代器摄取数据。该预定义的数据接收器支持写入文件和标准输入输出及socket。1.2 绑定连接器 连接器提供用于与各种第三方系统连接…
2021/7/7 17:09:07 人评论 次浏览 -
Flink实战(八) - Streaming Connectors 编程
1 概览 1.1 预定义的源和接收器 Flink内置了一些基本数据源和接收器，并且始终可用。该预定义的数据源包括文件，目录和插socket，并从集合和迭代器摄取数据。该预定义的数据接收器支持写入文件和标准输入输出及socket。 1.2 绑定连接器 连接器提供用于与各种第三方系统连…
2021/7/7 17:08:15 人评论 次浏览 -
大牛手把手带你！mysql详细教程
一、对Kafka的认识 1.Kafka的基本概念 2.安装与配置 3.生产与消费 4.服务端参数配置二、生产者 1.客户端开发 2.原理分析 3.重要的生产者参数三、消费者 1.消费者与消费组 2.客户端开发四、主题与分区 1.主题的管理 2.初识KafkaAdminCilent 3.分区的管理 4.如何选择合适的…
2021/7/7 2:04:49 人评论 次浏览 -
大数据平台复习11.Spark streaming
流数据 大数据的两种存在形式：静态和动态 静态大数据：已经积累产生并存在那里的大数据 动态大数据：随着时间的推移不断的产生的大数据 各种摄像头的监控数据 12306的订票请求 银行的交易请求 Storm 最早是由Nathan Marz和他的团队于2010年在数据分析公司BackType开发 2…
2021/7/6 23:35:04 人评论 次浏览 -
初步理解类加载运行机制和类加载过程，Java面试真题精选
一、对Kafka的认识 1.Kafka的基本概念 2.安装与配置 3.生产与消费 4.服务端参数配置二、生产者 1.客户端开发 2.原理分析 3.重要的生产者参数三、消费者 1.消费者与消费组 2.客户端开发四、主题与分区 1.主题的管理 2.初识KafkaAdminCilent 3.分区的管理 4.如何选择合适的…
2021/6/28 22:20:47 人评论 次浏览 -
spark-streaming
import org.apache.kafka.clients.consumer.ConsumerRecord import org.apache.kafka.common.serialization.StringDeserializer import org.apache.spark.SparkConf import org.apache.spark.rdd.RDD import org.apache.spark.streaming.{Seconds, StreamingContext} imp…
2021/6/27 23:24:29 人评论 次浏览 -
Streaming Systems：Concept
流式数据处理在当今大数据领域是非常重要，这是有足够充分的理由的，如下： 企业需要更及时地洞察他们的数据，而流式数据是实现更低延迟的一个好方法；现在商业中有海量无界的数据，使用为永不结束的数据设计的系统处理它们就更为容易；当数据一到达就进行处理，工作负载…
2021/6/27 23:22:16 人评论 次浏览 -
java数组初始化赋值，聪明人已经收藏了！
一、对Kafka的认识 1.Kafka的基本概念2.安装与配置3.生产与消费4.服务端参数配置二、生产者 1.客户端开发 必要的参数配置消息的发送序列化分区器生产者拦截器2.原理分析 整体架构元数据的更新3.重要的生产者参数三、消费者 1.消费者与消费组2.客户端开发 必要的参数配置订…
2021/6/27 17:53:02 人评论 次浏览 -
Flink实战（八十六）：flink-sql使用（十三）Flink 与 hive 结合使用（五）Hive Streaming
声明：本系列博客是根据SGG的视频整理而成，非常适合大家入门学习。 《2021年最新版大数据面试题全面开启更新》 0 Hive Streaming A typical hive job is scheduled periodically to execute, so there will be a large delay. Flink supports to write, read and join t…
2021/6/11 2:27:32 人评论 次浏览
