看完了Flink的datasource、sink，也就把一头一尾给看完了，从数据流入到数据流出，缺少了中间的处理环节。 而flink的大头恰恰是只在这个中间环节，如下图： 中...
发简信
IP属地：北京
-
flink学习之七-map、fliter、flatmap
-
TensorFlow 和 NumPy 的 Broadcasting 机制探秘在使用Tensorflow的过程中，我们经常遇到数组形状不同的情况，但有时候发现二者还能进行加减乘除的运算，在这背后，其实是Tensorflow的broadcast即广播机制...
-
hive lateral view explode (array()） array为null
谈一下使用hive udtf 函数lateral view explode(array()) array为空时遇到的坑，这个UDTF转换的Array为空的记录，自动被过滤掉...
-
pandas中.value_counts()的用法value_counts()是一种查看表格某列中有多少个不同值的快捷方法，并计算每个不同值有在该列中有多少重复值。value_counts()是Series拥有的方法，一般在...
-
工厂模式，依赖，依赖注入
工厂模式 通过一个类来管理多个不同类的生成，如在一个类中，里面有多个对象实例化，当你需要一些新类时或者其他状况需要变更类，普通情况下你只能在这个类中重新编写代码，如有一个类来...
-
设计模式之死磕工厂模式（原创）工厂模式（Factory Pattern）是开发中比较常用的设计模式之一。这种类型的设计模式属于创建型模式（关于创建型模式的概念，可以参考设计模式概念与简介，简单点理解就是创...
-
JAVA 将接口的引用指向实现类的对象
有一个很简单的例子,java.util中的类ArrayList实现了接口List则生成ArrayList对象时可用以下语句. List list=new ArrayList(...
-
互联网AbTest系统设计思考ABTest系统背景 互联网与传统软件行业的开发最大区别就是快速迭代,新增一个业务或者新增一个基于老业务的算法更新也许只是某个工程师一天的结果。在这种代码高速发布过程中, 必...
-
Tensorflow-API ：对于tensor特定值进行逻辑判断和操作
1.比较函数 2.这些比较函数会输出bool类型的tensor,那么就可以配合tf.where来使用 x中为true的元素值不变，false的元素值替换为y中对应位置的值，因...
