勋章
我关注的人
粉丝
技术能力
暂时未有相关云产品技术能力~
暂无个人介绍
-
发表了文章 2022-05-18
Flink之Table API与SQL（一）
笔记
-
发表了文章 2022-05-18
Flink之Queryable State的使用
笔记
-
发表了文章 2022-05-18
Flink之Checkpoint机制
笔记
-
发表了文章 2022-05-18
Flink之状态后端（StateBackends）
每传入一条数据，有状态的算子任务都会 读取和更新状态 。由于有效的状态访问对于处 理数据的低延迟至关重要，因此每个并行任务(子任务)都会在本地维护其状态，以确保快速 的状态访问。
-
发表了文章 2022-05-18
Flink之状态一致性
当在分布式系统中引入状态时，自然也引入了一致性问题。 一致性实际上是"正确性级别"的另一种说法，也就是说在成功处理故障并恢复之后得到 的结果，与没有发生任何故障时得到的结果相比，前者到底有多正确？举例来说，假设要对 最近一小时登录的用户计数。在系统经历故障之后，计数结果是多少？如果有偏差，是有漏 掉的计数还是重复计数？
-
发表了文章 2022-05-18
Flink之状态编程OperatorState的使用
笔记
-
发表了文章 2022-05-18
Mac中PyCharm配置Anaconda环境的方法
笔记
-
发表了文章 2022-05-18
Flink之状态编程KeyedState的使用
笔记
-
发表了文章 2022-05-18
Day5-Java面试题之int与Integer区别
笔记
-
发表了文章 2022-05-18
Flink之状态编程
有状态的计算是流处理框架要实现的重要功能，因为稍复杂的流处理场景都需要记录状 态，然后在新流入数据的基础上不断更新状态。 SparkStreaming 在状态管理这块做的不好, 很多时候需要借助于外部存储(例如 Redis) 来手动管理状态, 增加了编程的难度。 Flink 的状态管理是它的优势之一。
-
发表了文章 2022-05-18
Java SE面试题集合（二）
笔记
-
发表了文章 2022-05-18
Java SE面试题集合（一）
笔记
-
发表了文章 2022-05-18
Flink之外部数据访问的异步 I/O
笔记
-
发表了文章 2022-05-18
Flink之ProcessFunction
我们之前学习的转换算子是无法访问事件的时间戳信息和水位线信息的。而这在一些应 用场景下，极为重要。例如 MapFunction 这样的map 转换算子就无法访问时间戳或者当前事 件的事件时间。 基于此，DataStream API 提供了一系列的 Low-Level 转换算子。可以访问时间戳、 watermark 以及注册定时事件。还可以输出特定的一些事件，例如超时事件等。Process Function用来构建事件驱动的应用以及实现自定义的业务逻辑(使用之前的 window 函数和 转换算子无法实现)。例如，Flink SQL 就是使用Process Function 实现的。
-
发表了文章 2022-05-18
Flink之join多流合并
笔记
-
发表了文章 2022-05-18
Flink之window机制
笔记
-
发表了文章 2022-05-18
Flink之Time与Watermark（二）
笔记
-
发表了文章 2022-05-18
Flink之Time与Watermark（一）
笔记
-
发表了文章 2022-05-18
Mac如何将本地项目上传至GitHub
笔记
-
发表了文章 2022-05-18
Flink之DataStream转换操作
笔记
-
发表了文章 2022-05-18
Flink之DataStream数据源
笔记
-
发表了文章 2022-05-18
Flink之DataSet语义注释、广播变量、分布式缓存及参数传递
笔记
-
发表了文章 2022-05-18
Flink之DataSet迭代计算
笔记
-
发表了文章 2022-05-18
Flink之DataSet数据输出
笔记
-
发表了文章 2022-05-18
Flink之DataSet转换操作（二）
笔记
-
发表了文章 2022-05-18
Flink之DataSet转换操作（一）
笔记
-
发表了文章 2022-05-18
Flink之DataSet数据源
笔记
-
发表了文章 2022-05-18
Flink编程模型
笔记
-
发表了文章 2022-05-17
Apache Flink1.12开发环境配置
笔记
-
发表了文章 2022-05-17
Centos7下Apache Flink1.12安装部署
笔记
-
发表了文章 2022-05-17
Flink架构原理
笔记
-
发表了文章 2022-05-17
浅谈Flink概述及特点
笔记
-
发表了文章 2022-05-17
ES集群规划
笔记
-
发表了文章 2022-05-17
推荐系统之基于关联规则推荐
笔记
-
发表了文章 2022-05-17
协同过滤推荐之基于模型协同过滤
笔记
-
发表了文章 2022-05-17
推荐系统之基于用户画像推荐
笔记
-
发表了文章 2022-05-17
NTP设置集群时间同步
笔记
-
发表了文章 2022-05-17
基于ES之业务数据分组求和TopN开发
需求：把作家所有作品的总点击数加起来求和再进行排序的一个实现
-
发表了文章 2022-05-17
基于ES之业务数据分类聚合开发
笔记
-
发表了文章 2022-05-17
Java数据结构线性表之顺序表
笔记
-
发表了文章 2022-05-17
Centos7下ELK安装部署
笔记
-
发表了文章 2022-05-15
Redis超全精讲！（三）
介： 课程目标 能够掌握Redis不同数据类型操作 能够使用Java API操作Redis 能够理解Redis的两种持久化方式 能够理解Redis的主从复制架构 能够理解Redis的Sentinel架构 能够理解Redis集群架构
-
发表了文章 2022-05-15
Redis超全精讲！（二）
课程目标 能够掌握Redis不同数据类型操作 能够使用Java API操作Redis 能够理解Redis的两种持久化方式 能够理解Redis的主从复制架构 能够理解Redis的Sentinel架构 能够理解Redis集群架构
-
发表了文章 2022-05-15
Redis超全精讲！（一）
课程目标 能够掌握Redis不同数据类型操作 能够使用Java API操作Redis 能够理解Redis的两种持久化方式 能够理解Redis的主从复制架构 能够理解Redis的Sentinel架构 能够理解Redis集群架构
-
发表了文章 2022-05-15
Storm与MySQL的集成
笔记
-
发表了文章 2022-05-15
Storm与Kafka的集成
笔记
-
发表了文章 2022-05-15
Storm中Trident State详解
笔记
-
发表了文章 2022-05-15
Storm中Trident Operations详解（二）
笔记
-
发表了文章 2022-05-15
Storm中Trident Operations详解（一）
笔记
-
发表了文章 2022-05-15
Storm中Trident框架详解
笔记
-
发表了文章
2022-05-19
一篇文章搞懂数据埋点与数据同步
-
发表了文章
2022-05-19
大数据开发工程师需要了解的【数仓中事实表的设计】
-
发表了文章
2022-05-19
大数据开发工程师需要了解的【数仓中的维度设计】（二）
-
发表了文章
2022-05-19
大数据开发工程师需要了解的【数仓中的维度设计】（一）
-
发表了文章
2022-05-19
大数据开发工程师需要了解的【数仓中的指标体系】
-
发表了文章
2022-05-19
Hive中collect_list()排序问题详解
-
发表了文章
2022-05-19
一篇文章讲清楚数据仓库模型设计！
-
发表了文章
2022-05-19
数仓学习|几种常见的数据同步方式
-
发表了文章
2022-05-19
Hive Distinct 的实现原理
-
发表了文章
2022-05-19
Hive之count(distinct xxx)优化写法
-
发表了文章
2022-05-19
数仓学习|初始数仓
-
发表了文章
2022-05-19
MySQL常见面试题汇总（建议收藏！！！）（二）
-
发表了文章
2022-05-19
MySQL常见面试题汇总（建议收藏！！！）（一）
-
发表了文章
2022-05-19
MySQL聚簇索引和非聚簇索引的区别
-
发表了文章
2022-05-19
Java数据结构线性表之链表（二）
-
发表了文章
2022-05-19
Java数据结构线性表之链表（一）
-
发表了文章
2022-05-19
Day11-Java中String的equals方法如何实现
-
发表了文章
2022-05-19
Day10-Java中HashMap几种遍历方式与性能分析
-
发表了文章
2022-05-19
Day9-Java线程中run方法和start方法的区别
-
发表了文章
2022-05-19
Day8-Java线程中join方法的使用
