API要的就是这个类型
Spark：DataFrame写HFile （Hbase）一个列族、一个列扩展一个列族、多个列扩展:Spark:DataFrame生成HFile 批量导入Hbase在上一篇博文中遗留了一个问题，就是只能处理DataFrame 的一行一列,虽然给出一个折中的办法处理多个...
发简信
IP属地：香港
-
-
可以实现，但是应该不是最佳最佳方案
flink 自定义触发器 定时或达到数量触发
flink 触发器 触发器确定窗口(由窗口分配程序形成)何时准备由窗口函数处理。每个WindowAssigner都带有一个默认触发器。如果默认触发器不适合需求，我们就需要自定...
-
算法系列-动态规划(2)：切割钢材问题
切割钢材问题 接上回说到，斐波那契数列是动态规划最简单应用，但动态规划却不是为了用来算那数列。 当时留了个尾巴，就是切割钢材的问题。 不同长度的钢材价格不一样，我现在有一根长...
-
算法系列-动态规划(1)：初识动态规划昨天，罗拉去面试回来，垂头丧气。显然是面试不顺利，我赶忙过去安慰。 经过询问才知道，罗拉面试挂在了动态规划。 说到动态规划，八哥可就来精神了，于是就结合劳拉的面试题简单的和她...
-
eventInputDT 是数据源，但是这里只是一个自定义触发器，跟你是什么数据源没有关系。你读取mysql的数据应该是要通过自定义数据源来实现的。关键是你自定义输入的时候怎噩梦读取mysql的数据，和这个触发器本身的关系不大。ps：一般读取mysql之类的好像也不常用，flink 还是配合kafka数据源比较合适
flink 自定义触发器 定时或达到数量触发
flink 触发器 触发器确定窗口(由窗口分配程序形成)何时准备由窗口函数处理。每个WindowAssigner都带有一个默认触发器。如果默认触发器不适合需求，我们就需要自定...
-
没什么好纠结的。你就说不方便。你不让她还能强行进来？你要是过意不去，也可以收租，收伙食费。如果你和你哥关系好，你哥就该做点什么。而不是让你为难。房子是你的，到哪里你都有理
我买了房，嫂子说带孩子过来一起住，我该怎么拒绝？
本人80后女，我和我哥从小没有父母，我小时候读书比较争气，毕业后找了一份相对稳定的工作，并且现在买了房，正准备装修中！ 我哥他们现在在省外打工，她放话说等我房子弄好了她带着她...
-
主要是 你即使换不上，我至少诶知道你是记得这回事的。
借的不是钱，是信任。
2月份的时候，一位同学找我借钱，当时口口声声说的是下个月15号发工资就还。 是的，是2月份的事，现在已经过了下下个月的15号了。 3月15的时候，没还，也没个信息，又过了几天...
-
我上大学的到刚工作的时候 陆陆续续借了朋友4千多，
前几天跟他对账，
明面还欠我三千多，愣说了个1000多。
我让他对支付宝账单几次才对出来
18年到现在了啊
也就才三四千块钱。
哎真他妈的老实人活该吃亏借的不是钱，是信任。
2月份的时候，一位同学找我借钱，当时口口声声说的是下个月15号发工资就还。 是的，是2月份的事，现在已经过了下下个月的15号了。 3月15的时候，没还，也没个信息，又过了几天...
-
ExceptionInChainedOperatorException：flink写hbase对于null数据导致数据导致出现异常
使用的flink版本：1.9.1 异常描述 需求： 从kafka读取一条数据流 经过filter初次筛选符合要求的数据 然后通过map进行一次条件判断再解析。这个这个过程中可...
-
flink自定义窗口分配器 周、月关于分配器介绍内容来自官网 窗口分配的概念 窗口分配程序（Window Assigners）定义如何将元素分配给窗口。通过window(...) (for keyed str...
-
二叉树的遍历实现递归与非递归本文实现了二叉树的深度遍历算法，分为递归与非递归 递归的实现非常简单，基本上没啥难度 非递归的实现需要根据遍历的顺序，将递归转换成循环 代码中的二叉树如下 递归 递归的实现很...
-
flink 自定义触发器 定时或达到数量触发flink 触发器 触发器确定窗口(由窗口分配程序形成)何时准备由窗口函数处理。每个WindowAssigner都带有一个默认触发器。如果默认触发器不适合需求，我们就需要自定...
-
hbase-spark bulk load(二)概述 之前写过spark批量导入Hbase的案例：Spark、BulkLoad Hbase、单列、多列，实现了多列的操作。整个过程涉及到排序、分解等操作相对复杂。 最近看官网...