成功案例建議 找到適合自己的長期戰(zhàn)略目標 專注深耕一個細分領(lǐng)域，保持定力 長期投入，投入5-10年 年度細分計劃+持續(xù)可量化的價值產(chǎn)出 學習 學習金字塔和刻意訓練 個人思考 ...
IP屬地：重慶
-
-
Flink Streaming File Sink背景 Flink 支持將流數(shù)據(jù)以文件形式存儲到外部系統(tǒng)，典型使用場景是將數(shù)據(jù)寫入Hive表所在 HDFS存儲路徑，通過Hive 做查詢分析。隨著Flink文件寫入被業(yè)務(wù)廣泛使...
-
Alluxio：架構(gòu)及數(shù)據(jù)流1 架構(gòu) 1.1 概述 Alluxio作為大數(shù)據(jù)和機器學習生態(tài)系統(tǒng)中的一個新的數(shù)據(jù)訪問層，配置在任何持久性存儲系統(tǒng)(如Amazon S3、Microsoft Azure...
-
行存儲、列存儲、行列混存行存儲 我們常用的關(guān)系型數(shù)據(jù)庫mysql，oracle等都是基于行存儲，以最常用的mysql數(shù)據(jù)庫 innodb引擎為例,見下圖 多個連續(xù)的行記錄，組成一個data page...
-
flink使用14-使用SQL操作幾種window
Flink SQL 支持三種窗口類型, 分別為 Tumble Windows / HOP Windows 和 Session Windows. 其中 HOP windows ...
-
Linux下安裝Python3.6和pip
CentOS 7上默認安裝的python版本是2.7.5，系統(tǒng)自帶的舊版本python被系統(tǒng)很多其他軟件環(huán)境依賴，因此不能卸載原Python，直接選擇Python3.6.5進...
-
-
-
《我想進大廠》之kafka奪命連環(huán)11問干啥啥不行，看小說第一名。這不，好好寫了一篇文章。 最近整理了一下文章目錄，因為好早之前就有兄弟跟我說之前文章找不到，我也懶得整理，現(xiàn)在好好整了一下，發(fā)現(xiàn)有一篇文章寫了一半我...
-
Kafka會不會丟消息
原文地址：https://mp.weixin.qq.com/s/TScpvjpIlyZyj62e8EwOPg[https://mp.weixin.qq.com/s/TScpv...
-
Clickhouse 實現(xiàn)分時統(tǒng)計利用clickhouse中的toStartOf*()函數(shù)，將時間歸屬到相同點，然后利用分組統(tǒng)計即可。 toStartOf*()函數(shù)： toStartOfInterval() ...
-
Hive窗口分析函數(shù)
1、概念 窗口分析函數(shù)：窗口函數(shù)也稱為OLAP（OnlineAnalytical Processing）函數(shù)，是對一組值進行操作，不需要使用Group by子句對數(shù)據(jù)進行分組...
-
hello 怎么判斷查到的數(shù)據(jù)為空
Prometheus 查詢語言
[TOC] Prometheus 查詢語言 PromQL（Prometheus Query Language）是 Prometheus 自己開發(fā)的表達式語言，語言表現(xiàn)力很豐富...
-
Flink拆分流和復制流
使用旁路輸出(side output)來拆分和復制流??我們在處理數(shù)據(jù)的時候，有時候想對不同情況的數(shù)據(jù)進行不同的處理，那么就需要把流進行拆分或者復制。如果是使用filter來...