之前看 Flink Source 的 metrics 时候,看到 FlinkKafkaConsuemr 消费 Kafka 数据的代码,感觉比较有意思,就仔细看下了 大致流程如下: FlinkKafKaConsuemr 的启动流程就不细讲了,直接跳到 FlinkKafkaConsumerBase.ru ...
分类:
其他好文 时间:
2020-09-17 13:20:14
阅读次数:
29
(1)rank over(order by 列名) 该函数只适用于oracle 例: 1 select sid, sname, rank() over (order by score) as srank from sc; (2)rank over(partition by 列名,order by 列 ...
分类:
其他好文 时间:
2020-09-17 13:16:08
阅读次数:
34
并发与并行并发:两个或者多个事件在同一时间段发生(交替执行)并行:两个或者多个事件在同一时刻发生(cpu多核、同时执行)线程与进程进程:是一个内存中运行的应用程序,有自己独立的内存空间,一个应用程序至少有一个进程,一个进程至少有一个线程;线程:线程是进程中的一个执行单元,是CPU调度和分派的基本单位,能独立运行的基本单位,同一进程中的多个线程之间可以并发执行。线程调度:分时调度:所有线程轮流使用C
分类:
编程语言 时间:
2020-09-17 13:05:06
阅读次数:
35
@Override public List<Map<String, Object>> getModuleTree(List<Map<String, Object>> list ,String flowId) { List<?> modulesId = getModulesId(flowId); mo ...
分类:
编程语言 时间:
2020-09-17 12:57:50
阅读次数:
36
前几天遇到一个这样的需求:销售总占比加起来超过75%的top分类。具体需求是这样的:商品一级分类标签下面有许多商品标签,例如运动户外一级标签,下面可能存在361°,CBA,Nike,Adidas...等这些商品标签。我们需要统计在一级标签下面占总销售比超过75%的商品标签有哪些,从而让我们了解一级品... ...
分类:
其他好文 时间:
2020-09-16 12:19:01
阅读次数:
73
两个排序列表的相似性 在信息检索领域,我们常用MAP、MRR、NDCG来评估排序算法的好坏,然而这些指标依赖人工标注的query与document的相关性档位(relevance level)。当没有此标注数据,或者我们要评估的排序列表跟相关性无关,并且我们刚好有一个待比较的基准列表时,该如何评估它... ...
分类:
其他好文 时间:
2020-09-15 21:08:54
阅读次数:
37
Invalid bound statement (not found) ...
分类:
编程语言 时间:
2020-09-14 19:15:55
阅读次数:
50
vue.vonfig.js 这个文件引入mian.scss css: { // 是否使用css分离插件 ExtractTextPlugin extract: true, // 开启 CSS source maps? sourceMap: false, // css预设器配置项 loaderOptio ...
分类:
Web程序 时间:
2020-09-12 21:41:04
阅读次数:
55
1.函数说明 主要是配合over()窗口函数来使用的,通过over(partition by order by )来反映统计值的记录。 1. rank() over()是跳跃排序,有两个第二名时接下来就是第四名(同样是在各个分组内) 2. dense_rank() over()是连续排序,有两个第二 ...
分类:
其他好文 时间:
2020-09-11 16:15:16
阅读次数:
58
多态性(面向对象特征三) 多态性在Java中有三种体现: 方法的重载overload 方法的重写override 对象的多态性——主要应用在抽象类和接口上 对象的多态性:Java引用变量有两个类型,编译时类型,运行时类型。编译时类型有声明该变量时使用的类型决定,运行时类型由实际赋给该变量的对象决定。 ...
分类:
编程语言 时间:
2020-09-09 18:55:25
阅读次数:
39