介紹 最近涉及 Nginx 輸出的埋點(diǎn)日志,實(shí)時(shí)接入 Kafka,我需要實(shí)時(shí)解析 Kafka 中埋點(diǎn)日志,但是在解析過(guò)程中,出現(xiàn) \x22 這...
概述 Java 中的 final 關(guān)鍵字非常重要,它可以應(yīng)用與類、方法以及變量。這篇文章中我將帶你看看: 什么是 final 關(guān)鍵字? 將變量、...
不可變類介紹 不可變類: 所謂的不可變類是指這個(gè)類的實(shí)例一旦創(chuàng)建完成后,就不能修改其成員變量值。如JDK 內(nèi)部自帶的很多不可變類:Integer...
說(shuō)明 最近在做 Hive 事實(shí)表 left join 多張維表時(shí),出現(xiàn)了部分?jǐn)?shù)據(jù)丟失的情況(結(jié)果表數(shù)據(jù)量比原始事實(shí)表少 10000 多條),針對(duì)...
說(shuō)明 在最近的項(xiàng)目中,需要將最終生成的 Hive 表數(shù)據(jù)導(dǎo)出到文件中,具體實(shí)現(xiàn)請(qǐng)參見(jiàn)下方 SQL。 查詢結(jié)果導(dǎo)入到 hdfs 文件 一般方式: ...
說(shuō)明 在最近的項(xiàng)目中,時(shí)間數(shù)據(jù)是以秒的形式展現(xiàn)的,需要將時(shí)間轉(zhuǎn)換成 UTC + 0800 的形式,才有了如下代碼。 代碼實(shí)現(xiàn)
問(wèn)題展示 在 Scala 編程中經(jīng)常會(huì)使用 Java 的集合類型,但是使用中會(huì)出現(xiàn)如下錯(cuò)誤: java.util.List[String] 2....
Apache Flink社區(qū)很高興地宣布Apache Flink 1.7.0。最新版本包括超過(guò)420個(gè)已解決的問(wèn)題以及Flink的一些令人興奮的...
基本用法 Shell 的 if 語(yǔ)法 和 C 語(yǔ)言等高級(jí)語(yǔ)言非常相似,唯一需要注意的地方就是 Shell 的 if 語(yǔ)句對(duì)空格方面的要求比較嚴(yán)格...