240 发简信
IP属地:北京
  • scala尾递归实现斐波那契数列(LeetCode509)

    斐波那契数列形如1, 1, 2, 3, 5, 8...,即每个元素都是上两个元素之和,f(n) = f(n-1) + f(n-2) 思路: 初值:使用一对参数(a, b),a...

  • scala隐式转换实现reduceByKey

    先看下spark实现word count的方式 如果不用spark框架,而用scala语言直接实现,因为scala原本没有reduceByKey这个操作,需要通过隐式转换实现...

  • 在process里面用table.batch有意义吗?

    structuredStreaming 实时将数据写入到redis,hbase,自定义sink组件

    需要自定义一个sink组件,其实很简单,只需要继承ForeachWriter,实现相关的方法即可。class RedisSink extends ForeachWriterR...