一、需求背景 针对算法产生的日志数据进行清洗拆分 1、算法产生的日志数据是嵌套json格式,需要拆分打平 2、针对算法中的国家字段进行大区转换 3、把数据回写到 Kafka ...
IP属地:浙江
一、需求背景 针对算法产生的日志数据进行清洗拆分 1、算法产生的日志数据是嵌套json格式,需要拆分打平 2、针对算法中的国家字段进行大区转换 3、把数据回写到 Kafka ...
前言 1 Flink基础(适合初入职场) 简单介绍一下 Flink Flink相比传统的Spark Streaming区别? Flink的组件栈有哪些? Flink 的运行必...
我们看事务的源码,不仅是为了更好地使用Spring,而且能够从源码中学习到编程思想,设计思想。这篇文章框架如图所示: 一、相关知识 MySQL事务 事务的启动 显式启动事务语...
最新在线上更新了代码之后导致了任务在消费kafka数据的时候,突然就不消费数据了,发现原因在公司的可视化界面中,看不到数据的更新,进入flink监控页面中看到任务没有fail...
1:HashMap 的数据结构? 2:HashMap 的工作原理? 3.当两个对象的 hashCode 相同会发生什么? 4.你知道 hash 的实现吗?为什么要这样实现? ...
前言 疫情如雾霾笼罩着大多数今年应届求职者的心,找不到好工作成为一大难题,许多小伙伴面试不上自己心仪的工作都靠兼职度日。没有成熟的项目经验,如何在人群中脱颖而出,将大厂off...
关于二叉树的问题,也就是涉及二叉树的四种遍历算法以及基本的删除、插入等操作 中序遍历和前序遍历/后序遍历的结合 题目7:重建二叉树 层序遍历 题目32:①从上到下打印二叉树 ...