序 本文主要研究一下flink的TableFunction 例項 // The generic type "Tuple2<String, Integer>" determ

date: 2019-01-07 18:19:42 title: tech| kafka入門書籍導讀 梳理了一下自己在入門 kafka 時讀過的一些書, 希望能幫助到對 k

序 本文主要研究一下flink的TableFactory 例項 class MySystemTableSourceFactory implements StreamTableSourceFactor

序 本文主要研究一下flink的CsvTableSink TableSink flink-table_2.11-1.7.1-sources.jar!/org/apache/flink/table/s

序 本文主要研究一下flink的CsvTableSource TableSource flink-table_2.11-1.7.1-sources.jar!/org/apache/flink/tab

PS：本文僅作技術分析，禁止用於其它非法用途 首先，自我介紹一下。小白一名，2017年才接觸Web滲透測試，至於為啥，當然是自己的網站被攻破了…… 進入正題，隨著安全意思增強，各企業對自

Apache Shiro 是Java的 安全框架 ，提供了認證（Authentication）、授權（Authorization）、會話（Session）管理、加密（Cryptography）等功能，且

序 本文主要研究一下flink Table Schema的定義 例項 定義欄位及型別 .withSchema( new Schema() .field("MyField1&#

Kudu這東西估計很多同學都聽過但是沒用過，那麼我們先從最基本的問題開始：kudu是什麼？能做什麼？ kudu是什麼？ kudu和Hbase類似也是一個分散式資料庫，據官方給它的定位是

一 kafka consumer準備                        前面的章節進行了分散式job的自動計算的概念講解以及實踐。上次分散式日誌說過日誌寫進kafka，是需要進行處理，以便合理的

本文為《 CVE-2018-11759]Apache mod_jk access control bypass 》的翻譯文章。 嘿，各位大佬們： 我非常激動向你們介紹一個我同事（ID為Xel）

序 本文主要研究一下flink Table的Set Operations 例項 Union Table left = tableEnv.fromDataSet(ds1, "a, b, c

這裡翻譯一篇關於 Kafka 實踐的文章，內容來自 DataWorks Summit/Hadoop Summit  上一篇分享，PPT 參考 https://www.slideshare.net/Hadoop

歡迎關注公眾號：n平方 本文主要介紹【 Kafka Streams的架構和使用 】 目標 瞭解kafka streams的架構。 掌握kafka streams程式設計。

在開源世界裡，Apache Storm專案是流處理的先鋒。Storm最早由Nathan Marz和創業公司BackType的一個團隊開發，後來才被Apache基金會接納。Storm提供了低延遲的流處理，但是它