如今，每個組織中都在大量使用實時處理。欺詐檢測，醫療保健中的實時警報和網路攻擊警報等用例需要實時處理即時資料。即使是幾毫秒的延遲也會產生巨大的影響。這種實時用例的理想工具是可以輸入資料流而不是批處理的工具。apache flink是該實時處理工具
解壓
[root@mypc01 bin]
# tar -zxvf flink-1.12.0-bin-scala_2.11.gz -c /usr/local
# 去bin目錄下啟動
[root@mypc01 bin]
# ./start-cluster.sh
/#/overview測試 wordcount案例,自帶的例子裡面有,用flink命令執行
[root@mypc01 flink-1.12.0]
# flink run examples/streaming/wordcount.jar
executing wordcount example with default input data set.
use --input to specify file input.
printing result to stdout. use --output to specify output path.
job has been submitted with jobid 415fe39eb83b91294ad200961fe99bf1
program execution finished
job with jobid 415fe39eb83b91294ad200961fe99bf1 has finished.
job runtime: 1201 ms
[root@mypc01 flink-1.12.0]
# tail log/flink-*-taskexecutor-*.out
(nymph,1)
(in,3)
(thy,1)
(orisons,1)
(be,4)
(all,2)
(my,1)
(sins,1)
(remember,1)
(d,4)
Flink 1 11 1 安裝及使用
軟體安裝 本地模式安裝 集群模式安裝使用 軟體安裝 官網位址 本地模式安裝 進入目錄 cd alidata server hadoop 解壓檔案 tar zxvf flink 1.11.1 bin scala 2.11.tgz 新增環境變數 vim etc profile flink export ...
Flink 基礎入門
作為致力於提供 stateful computations over data streams 的 下一代大資料處理引擎 flink 在流式計算領域帶來了諸多全新特性。本場 chat，我們將從 0 開始，幫助讀者入門 flink，主要內容包括 流式計算的目標與傳統架構 flink 基礎結構 flin...
Flink安裝部署
flink概述 apache flink是乙個框架和分布式處理引擎，用於對無界和有界資料流進行有狀態計算。flink設計為在所有常見的集群環境中執行，以記憶體速度和任何規模執行計算。flink特點 1 隨處部署應用 與其它元件整合！flink是分布式系統，需要計算資源才可執行程式。flink可以與常...