API要的就是這個類型
Spark：DataFrame寫HFile （Hbase）一個列族、一個列擴展一個列族、多個列擴展:Spark:DataFrame生成HFile 批量導入Hbase在上一篇博文中遺留了一個問題，就是只能處理DataFrame 的一行一列,雖然給出一個折中的辦法處理多個...
發(fā)簡信
IP屬地：廣東
-
-
可以實現(xiàn)，但是應該不是最佳最佳方案
flink 自定義觸發(fā)器 定時或達到數(shù)量觸發(fā)
flink 觸發(fā)器 觸發(fā)器確定窗口(由窗口分配程序形成)何時準備由窗口函數(shù)處理。每個WindowAssigner都帶有一個默認觸發(fā)器。如果默認觸發(fā)器不適合需求，我們就需要自定...
-
算法系列-動態(tài)規(guī)劃(2)：切割鋼材問題
切割鋼材問題 接上回說到，斐波那契數(shù)列是動態(tài)規(guī)劃最簡單應用，但動態(tài)規(guī)劃卻不是為了用來算那數(shù)列。 當時留了個尾巴，就是切割鋼材的問題。 不同長度的鋼材價格不一樣，我現(xiàn)在有一根長...
-
算法系列-動態(tài)規(guī)劃(1)：初識動態(tài)規(guī)劃昨天，羅拉去面試回來，垂頭喪氣。顯然是面試不順利，我趕忙過去安慰。 經過詢問才知道，羅拉面試掛在了動態(tài)規(guī)劃。 說到動態(tài)規(guī)劃，八哥可就來精神了，于是就結合勞拉的面試題簡單的和她...
-
eventInputDT 是數(shù)據源，但是這里只是一個自定義觸發(fā)器，跟你是什么數(shù)據源沒有關系。你讀取mysql的數(shù)據應該是要通過自定義數(shù)據源來實現(xiàn)的。關鍵是你自定義輸入的時候怎噩夢讀取mysql的數(shù)據，和這個觸發(fā)器本身的關系不大。ps：一般讀取mysql之類的好像也不常用，flink 還是配合kafka數(shù)據源比較合適
flink 自定義觸發(fā)器 定時或達到數(shù)量觸發(fā)
flink 觸發(fā)器 觸發(fā)器確定窗口(由窗口分配程序形成)何時準備由窗口函數(shù)處理。每個WindowAssigner都帶有一個默認觸發(fā)器。如果默認觸發(fā)器不適合需求，我們就需要自定...
-
沒什么好糾結的。你就說不方便。你不讓她還能強行進來？你要是過意不去，也可以收租，收伙食費。如果你和你哥關系好，你哥就該做點什么。而不是讓你為難。房子是你的，到哪里你都有理
我買了房，嫂子說帶孩子過來一起住，我該怎么拒絕？
本人80后女，我和我哥從小沒有父母，我小時候讀書比較爭氣，畢業(yè)后找了一份相對穩(wěn)定的工作，并且現(xiàn)在買了房，正準備裝修中！ 我哥他們現(xiàn)在在省外打工，她放話說等我房子弄好了她帶著她...
-
主要是 你即使換不上，我至少誒知道你是記得這回事的。
借的不是錢，是信任。
2月份的時候，一位同學找我借錢，當時口口聲聲說的是下個月15號發(fā)工資就還。 是的，是2月份的事，現(xiàn)在已經過了下下個月的15號了。 3月15的時候，沒還，也沒個信息，又過了幾天...
-
我上大學的到剛工作的時候 陸陸續(xù)續(xù)借了朋友4千多，
前幾天跟他對賬，
明面還欠我三千多，愣說了個1000多。
我讓他對支付寶賬單幾次才對出來
18年到現(xiàn)在了啊
也就才三四千塊錢。
哎真他媽的老實人活該吃虧借的不是錢，是信任。
2月份的時候，一位同學找我借錢，當時口口聲聲說的是下個月15號發(fā)工資就還。 是的，是2月份的事，現(xiàn)在已經過了下下個月的15號了。 3月15的時候，沒還，也沒個信息，又過了幾天...
-
ExceptionInChainedOperatorException：flink寫hbase對于null數(shù)據導致數(shù)據導致出現(xiàn)異常
使用的flink版本：1.9.1 異常描述 需求： 從kafka讀取一條數(shù)據流 經過filter初次篩選符合要求的數(shù)據 然后通過map進行一次條件判斷再解析。這個這個過程中可...
-
flink自定義窗口分配器 周、月關于分配器介紹內容來自官網 窗口分配的概念 窗口分配程序（Window Assigners）定義如何將元素分配給窗口。通過window(...) (for keyed str...
-
二叉樹的遍歷實現(xiàn)遞歸與非遞歸本文實現(xiàn)了二叉樹的深度遍歷算法，分為遞歸與非遞歸 遞歸的實現(xiàn)非常簡單，基本上沒啥難度 非遞歸的實現(xiàn)需要根據遍歷的順序，將遞歸轉換成循環(huán) 代碼中的二叉樹如下 遞歸 遞歸的實現(xiàn)很...
-
flink 自定義觸發(fā)器 定時或達到數(shù)量觸發(fā)flink 觸發(fā)器 觸發(fā)器確定窗口(由窗口分配程序形成)何時準備由窗口函數(shù)處理。每個WindowAssigner都帶有一個默認觸發(fā)器。如果默認觸發(fā)器不適合需求，我們就需要自定...
-
hbase-spark bulk load(二)概述 之前寫過spark批量導入Hbase的案例：Spark、BulkLoad Hbase、單列、多列，實現(xiàn)了多列的操作。整個過程涉及到排序、分解等操作相對復雜。 最近看官網...