๋ณธ๋ฌธ ๋ฐ”๋กœ๊ฐ€๊ธฐ

์ „์ฒด ๊ธ€

(25)
[Apache Iceberg] Iceberg ์„ค๊ณ„ ์•„ํ‚คํ…์ฒ˜ ๋ฐ ์ฃผ์š” ํŠน์ง• ๐ŸงŠ Apache Iceberg: The Definitive Guide ์ฑ…์„ ๋ฐ”ํƒ•์œผ๋กœ ์ž‘์„ฑ๋˜์—ˆ์Šต๋‹ˆ๋‹ค. 1. How Did We Get Here? A Brief History2. The Data Warehouse 3. The Data Lake4. Should I Run Analytics on a Data Lake or a Data Warehouse?5. The Data Lakehouse6. What is a Table Format? 7. Hive : The Original Table Format 8. Modern Data Lake Table Formats 9. What is Apache Iceberg? โ—€๏ธŽ10. Conclusion โ—€๏ธŽ โ–บ Chapter 1. Introduction to Apache Ic..
[Apache Iceberg] Iceberg ์ด์ „์˜ Table Format, Hive ๐ŸงŠ Apache Iceberg: The Definitive Guide ์ฑ…์„ ๋ฐ”ํƒ•์œผ๋กœ ์ž‘์„ฑ๋˜์—ˆ์Šต๋‹ˆ๋‹ค. ๐Ÿ“ Chapter 1. Introduction to Apache Iceberg ๊ธ€ ๋ชจ์•„๋ณด๊ธฐ : โ–บ 1ํŽธ : [Apache Iceberg] ๋“ฑ์žฅ ๋ฐฐ๊ฒฝ (1) : OLAP์™€ Data Warehouseโ–บ 2ํŽธ : [Apache Iceberg] ๋“ฑ์žฅ ๋ฐฐ๊ฒฝ (2) : Data Lake์™€ Data Lakehouseโ–บ 4ํŽธ : [Apache Iceberg] Iceberg ์„ค๊ณ„ ์•„ํ‚คํ…์ฒ˜ ๋ฐ ์ฃผ์š” ํŠน์ง• ๐Ÿ’ก ๋“ค์–ด๊ฐ€๋ฉฐ์ง€๋‚œ ๊ธ€์—์„œ๋Š” Data Lake์™€ Data Lakehouse์— ๋Œ€ํ•ด ์‚ดํŽด๋ณด์•˜์Šต๋‹ˆ๋‹ค.์ด๋ฒˆ ๊ธ€์—์„œ๋Š” Apache Iceberg๊ฐ€ ๋“ฑ์žฅํ•˜๊ฒŒ ๋  ๋•Œ๊นŒ์ง€ Table Format์˜ ์—ญ์‚ฌ ํ๋ฆ„์— ๋Œ€ํ•ด ์งง๊ฒŒ ์‚ดํŽด๋ณด๋„๋ก ..
[Apache Iceberg] ๋“ฑ์žฅ ๋ฐฐ๊ฒฝ (2) : Data Lake์™€ Data Lakehouse ๐ŸงŠ Apache Iceberg: The Definitive Guide ์ฑ…์„ ๋ฐ”ํƒ•์œผ๋กœ ์ž‘์„ฑ๋˜์—ˆ์Šต๋‹ˆ๋‹ค. ๐Ÿ’ก ๋“ค์–ด๊ฐ€๋ฉฐ ์ง€๋‚œ ๊ธ€์—์„œ๋Š” ๋ฐ์ดํ„ฐ ๋ถ„์„์„ ์œ„ํ•œ OLAP์˜ ๊ฐœ๋… ๋ฐ ๊ตฌ์„ฑ ์š”์†Œ์™€, Data Warehouse์˜ ํŠน์ง•์— ๋Œ€ํ•ด ์‚ดํŽด๋ณด์•˜์Šต๋‹ˆ๋‹ค.์ด๋ฒˆ ๊ธ€์—์„œ๋Š” Data Warehouse์˜ ํ•œ๊ณ„๋ฅผ ๊ทน๋ณตํ•˜๊ธฐ ์œ„ํ•ด ๋“ฑ์žฅํ•œ Data Lake์— ๋Œ€ํ•ด ์•Œ์•„๋ณด๋„๋ก ํ•˜๊ฒ ์Šต๋‹ˆ๋‹ค. ๐Ÿ“ Chapter 1. Introduction to Apache Iceberg ๊ธ€ ๋ชจ์•„๋ณด๊ธฐ : โ–บ 1ํŽธ : [Apache Iceberg] ๋“ฑ์žฅ ๋ฐฐ๊ฒฝ (1) : OLAP์™€ Data Warehouseโ–บ 3ํŽธ : [Apache Iceberg] Table Format์ด๋ž€?, ๋Œ€ Hive Table Format์˜ ์‹œ๋Œ€ โ–บ 4ํŽธ : [Apache Iceber..
[Apache Iceberg] ๋“ฑ์žฅ ๋ฐฐ๊ฒฝ (1) : OLAP์™€ Data Warehouse ๐ŸงŠ Apache Iceberg: The Definitive Guide ์ฑ…์„ ๋ฐ”ํƒ•์œผ๋กœ ์ž‘์„ฑ๋˜์—ˆ์Šต๋‹ˆ๋‹ค. ๐Ÿ’ก ๋“ค์–ด๊ฐ€๋ฉฐ Apache Iceberg๋Š” ์ตœ๊ทผ ๋Œ€๊ทœ๋ชจ ๋ฐ์ดํ„ฐ๋ฅผ ์ €์žฅํ•˜๊ณ  ๊ด€๋ฆฌํ•  ๋•Œ ๋„๋ฆฌ ํ™œ์šฉ๋˜๊ณ  ์žˆ๋Š” ์˜คํ”ˆ ํ…Œ์ด๋ธ” ํฌ๋งท์ž…๋‹ˆ๋‹ค.์˜คํ”ˆ ํ…Œ์ด๋ธ” ํฌ๋งท์ด๋ž€ ์–ด๋–ค ๊ฐœ๋…์ผ๊นŒ์š”? ๊ทธ๋ฆฌ๊ณ  Apache Iceberg๋ฅผ ๋งŽ์€ ๊ณณ์—์„œ ์‚ฌ์šฉํ•˜๋Š” ์ด์œ ๋Š” ๋ฌด์—‡์ผ๊นŒ์š”?์ด๋ฅผ ์•Œ๊ธฐ ์œ„ํ•ด์„œ๋Š” Apache Iceberg๊ฐ€ ํƒ„์ƒํ•˜๊ฒŒ ๋œ ๋ฐฐ๊ฒฝ์„ ์ดํ•ดํ•˜๊ณ  ์žˆ์–ด์•ผ ํ•ฉ๋‹ˆ๋‹ค.์ด๋ฒˆ ๊ธ€์—์„œ๋Š” ๊ทธ ์ฒซ ๋ฒˆ์งธ๋กœ OLAP์™€ Data Warehouse์— ๋Œ€ํ•ด ์‚ดํŽด๋ณด๋„๋ก ํ•˜๊ฒ ์Šต๋‹ˆ๋‹ค. ๐Ÿ“ Chapter 1. Introduction to Apache Iceberg ๊ธ€ ๋ชจ์•„๋ณด๊ธฐ : โ–บ 2ํŽธ : [Apache Iceberg] ๋“ฑ์žฅ ๋ฐฐ๊ฒฝ (2) : Data Lake์™€..
Kafka Consumer Group Rebalancing(๋ฆฌ๋ฐธ๋Ÿฐ์‹ฑ) ๋“ค์–ด๊ฐ€๋ฉฐ Kafka Connect๋ฅผ ํ†ตํ•ด ๋ฐ์ดํ„ฐ๋ฅผ Sink ํ•˜๋Š” ๊ณผ์ •์—์„œ Commit ๋‚ด์šฉ์— ๋ฐ์ดํ„ฐ๊ฐ€ ํฌํ•จ๋˜์ง€ ์•Š๋Š” ํ˜„์ƒ์ด ๋ฐœ์ƒํ–ˆ์Šต๋‹ˆ๋‹ค. ๊ทธ๋กœ ์ธํ•ด ๋ฐ์ดํ„ฐ๊ฐ€ ์ค‘๋ณต ์ฒ˜๋ฆฌ๋˜๊ฑฐ๋‚˜ ๋ˆ„๋ฝ๋˜๋Š” ๋ฌธ์ œ๊ฐ€ ์ƒ๊ฒผ๊ณ , ์ผ์ •ํ•œ ํŒจํ„ด ์—†์ด ์‹œ๊ฐ„์ด ์ง€๋‚˜๋ฉด ๋‹ค์‹œ ์ •์ƒ ์ž‘๋™ํ•˜๋Š” ๊ฒฝ์šฐ๋„ ์žˆ์–ด ์›์ธ ํŒŒ์•…์ด ์‰ฝ์ง€ ์•Š์•˜์Šต๋‹ˆ๋‹ค. ์ด๋ฒˆ ๊ธ€์—์„œ๋Š” Sink Connector์˜ Consumer Override ์„ค์ •์„ ํ†ตํ•ด ๋นˆ๋ฒˆํ•œ ๋ฆฌ๋ฐธ๋Ÿฐ์‹ฑ ํ˜„์ƒ์œผ๋กœ ์ธํ•œ ๋ฐ์ดํ„ฐ ๋ถˆ์ผ์น˜ ํ˜„์ƒ์„ ํ•ด๊ฒฐํ•œ ๋‚ด์šฉ์„ ๊ณต์œ ๋“œ๋ฆฌ๊ณ ์ž ํ•ฉ๋‹ˆ๋‹ค. 1. ๋ฌธ์ œ ์ƒํ™ฉ2. Kafka Consumer Group์˜ Rebalancing ๋™์ž‘ ๊ณผ์ •3. Kafka Consumer Group์˜ Rebalancing์ด ๋ฐœ์ƒํ•˜๋Š” ๊ฒฝ์šฐ4. Sink Connector์˜ Consumer Override ์„ค์ •5...
[4์žฅ ๋ถ€ํ˜ธํ™”์™€ ๋ฐœ์ „] ๋ฐ์ดํ„ฐ ์ง๋ ฌํ™”(3) - ์Šคํ‚ค๋งˆ ๐Ÿ˜ BOAZ 23๊ธฐ ๋ฐ์ดํ„ฐ ์—”์ง€๋‹ˆ์–ด๋ง ๋ฉ˜๋ฉ˜ ์Šคํ„ฐ๋”” - "๋ฐ์ดํ„ฐ ์ค‘์‹ฌ ์• ํ”Œ๋ฆฌ์ผ€์ด์…˜ ์„ค๊ณ„" ์ฑ…์„ ๋ฐ”ํƒ•์œผ๋กœ ์ž‘์„ฑ๋˜์—ˆ์Šต๋‹ˆ๋‹ค. 3ํŽธ์—์„œ๋Š” ๋ฐ์ดํ„ฐ ์ง๋ ฌํ™”์˜ ๋งˆ์ง€๋ง‰์œผ๋กœ ์Šคํ‚ค๋งˆ์— ๋Œ€ํ•ด์„œ ์ž์„ธํžˆ ์•Œ์•„๋ณด์ž! โ˜๐Ÿป 1ํŽธ : ๋ฐ์ดํ„ฐ ์ง๋ ฌํ™”์˜ ๊ฐœ๋…https://nothing-study.tistory.com/33 [4์žฅ ๋ถ€ํ˜ธํ™”์™€ ๋ฐœ์ „] ๋ฐ์ดํ„ฐ ๋ถ€ํ˜ธํ™”(์ง๋ ฌํ™”) ํ˜•์‹ (1)๋ฐ์ดํ„ฐ ๋ถ€ํ˜ธํ™” ํ˜•์‹ํ”„๋กœ๊ทธ๋žจ์—์„œ๋Š” ๋ฐ์ดํ„ฐ๋ฅผ ํ‘œํ˜„ํ•ด์•ผ ํ•˜๋Š” ๋‘ ๊ฐ€์ง€ ์ƒํ™ฉ์ด ์žˆ๋‹ค.โ˜๐Ÿป ๋ฉ”๋ชจ๋ฆฌ์— ๋ฐ์ดํ„ฐ๋ฅผ ์ €์žฅํ•  ๋•ŒโœŒ๐Ÿป ํŒŒ์ผ์— ์“ฐ๊ฑฐ๋‚˜ ๋„คํŠธ์›Œํฌ๋ฅผ ํ†ตํ•ด ๋ฐ์ดํ„ฐ๋ฅผ ์ „์†กํ•  ๋•Œ ๋ฉ”๋ชจ๋ฆฌ์— ์ €์žฅnothing-study.tistory.com โœŒ๐Ÿป 2ํŽธ : Apache Thrift, Protocol Buffers, Avrohttps://nothing-study.tistory..
[4์žฅ ๋ถ€ํ˜ธํ™”์™€ ๋ฐœ์ „] ๋ฐ์ดํ„ฐ ์ง๋ ฌํ™” (2) - Thrift, Protocol Buffer, Avro ๐Ÿ˜ BOAZ 23๊ธฐ ๋ฐ์ดํ„ฐ ์—”์ง€๋‹ˆ์–ด๋ง ๋ฉ˜๋ฉ˜ ์Šคํ„ฐ๋”” - "๋ฐ์ดํ„ฐ ์ค‘์‹ฌ ์• ํ”Œ๋ฆฌ์ผ€์ด์…˜ ์„ค๊ณ„" ์ฑ…์„ ๋ฐ”ํƒ•์œผ๋กœ ์ž‘์„ฑ๋˜์—ˆ์Šต๋‹ˆ๋‹ค. 1ํŽธ์—์„œ ์ง๋ ฌํ™”์˜ ๊ฐœ๋…์— ๋Œ€ํ•ด ์‚ดํŽด๋ณด์•˜๋‹ค๋ฉด, ์ด์ œ ์กฐ๊ธˆ ๋” ์ž˜ ๋งŒ๋“ค์–ด์ง„ ์ง๋ ฌํ™” ๋ฐฉ์‹๋“ค์— ๋Œ€ํ•ด ํ•˜๋‚˜์”ฉ ์‚ดํŽด๋ณด์ž. ๐Ÿ‘‡๐Ÿป 1ํŽธ ๋ฐ”๋กœ๊ฐ€๊ธฐhttps://nothing-study.tistory.com/33 [4์žฅ ๋ถ€ํ˜ธํ™”์™€ ๋ฐœ์ „] ๋ฐ์ดํ„ฐ ๋ถ€ํ˜ธํ™”(์ง๋ ฌํ™”) ํ˜•์‹ (1)๋ฐ์ดํ„ฐ ๋ถ€ํ˜ธํ™” ํ˜•์‹ํ”„๋กœ๊ทธ๋žจ์—์„œ๋Š” ๋ฐ์ดํ„ฐ๋ฅผ ํ‘œํ˜„ํ•ด์•ผ ํ•˜๋Š” ๋‘ ๊ฐ€์ง€ ์ƒํ™ฉ์ด ์žˆ๋‹ค.โ˜๐Ÿป ๋ฉ”๋ชจ๋ฆฌ์— ๋ฐ์ดํ„ฐ๋ฅผ ์ €์žฅํ•  ๋•ŒโœŒ๐Ÿป ํŒŒ์ผ์— ์“ฐ๊ฑฐ๋‚˜ ๋„คํŠธ์›Œํฌ๋ฅผ ํ†ตํ•ด ๋ฐ์ดํ„ฐ๋ฅผ ์ „์†กํ•  ๋•Œ ๋ฉ”๋ชจ๋ฆฌ์— ์ €์žฅnothing-study.tistory.com ์ด๋ฒˆ ๊ธ€์—์„œ๋„ ์•„๋ž˜ JSON ๋ ˆ์ฝ”๋“œ๋ฅผ ์ด์ง„ ๋ถ€ํ˜ธํ™”ํ•ด๋ณด๋Š” ์˜ˆ์‹œ๋ฅผ ๋“ค์–ด๋ณผ ์˜ˆ์ •์ด๋‹ค3๏ธโƒฃ ์Šค๋ฆฌํ”„ํŠธ ์™€ ํ”„๋กœํ† ์ฝœ ๋ฒ„ํผ..
[4์žฅ ๋ถ€ํ˜ธํ™”์™€ ๋ฐœ์ „] ๋ฐ์ดํ„ฐ ์ง๋ ฌํ™” (1) - ๊ฐœ๋… ๐Ÿ˜ BOAZ 23๊ธฐ ๋ฐ์ดํ„ฐ ์—”์ง€๋‹ˆ์–ด๋ง ๋ฉ˜๋ฉ˜ ์Šคํ„ฐ๋”” - "๋ฐ์ดํ„ฐ ์ค‘์‹ฌ ์• ํ”Œ๋ฆฌ์ผ€์ด์…˜ ์„ค๊ณ„" ์ฑ…์„ ๋ฐ”ํƒ•์œผ๋กœ ์ž‘์„ฑ๋˜์—ˆ์Šต๋‹ˆ๋‹ค.๋ฐ์ดํ„ฐ ๋ถ€ํ˜ธํ™” ํ˜•์‹ํ”„๋กœ๊ทธ๋žจ์—์„œ๋Š” ๋ฐ์ดํ„ฐ๋ฅผ ํ‘œํ˜„ํ•ด์•ผ ํ•˜๋Š” ๋‘ ๊ฐ€์ง€ ์ƒํ™ฉ์ด ์žˆ๋‹ค.โ˜๐Ÿป ๋ฉ”๋ชจ๋ฆฌ์— ๋ฐ์ดํ„ฐ๋ฅผ ์ €์žฅํ•  ๋•ŒโœŒ๐Ÿป ํŒŒ์ผ์— ์“ฐ๊ฑฐ๋‚˜ ๋„คํŠธ์›Œํฌ๋ฅผ ํ†ตํ•ด ๋ฐ์ดํ„ฐ๋ฅผ ์ „์†กํ•  ๋•Œ ๋ฉ”๋ชจ๋ฆฌ → ๊ฐ์ฒด(object), ๊ตฌ์กฐ์ฒด(strcut), ๋ชฉ๋ก(list), ๋ฐฐ์—ด(array), ํŠธ๋ฆฌ(tree) ๊ฐ™์€ ๋ฐ์ดํ„ฐ ๊ตฌ์กฐํŒŒ์ผ/๋„คํŠธ์›Œํฌ → ์ปดํ“จํ„ฐ๊ฐ€ ์ดํ•ดํ•  ์ˆ˜ ์žˆ๋Š” ๋ฐ”์ดํŠธ์—ด์˜ ํ˜•ํƒœ๋กœ "๋ถ€ํ˜ธํ™”" ํ•„์š”๊ทธ๋ฆฌ๊ณ  ์ด ๋‘ ๊ฐ€์ง€ ํ‘œํ˜„ ์‚ฌ์ด์—์„œ ์ „ํ™˜์„ ํ•  ์ˆ˜ ์žˆ์–ด์•ผ ํ•œ๋‹ค.์ธ๋ฉ”๋ชจ๋ฆฌ ํ‘œํ˜„์—์„œ ๋ฐ”์ดํŠธ์—ด๋กœ์˜ ์ „ํ™˜์„ ๋ถ€ํ˜ธํ™”(=์ง๋ ฌํ™”, ๋งˆ์ƒฌ๋ง)๋ผ๊ณ  ํ•˜๋ฉฐ๊ทธ ๋ฐ˜๋Œ€๋ฅผ ๋ณตํ˜ธํ™”(=ํŒŒ์‹ฑ, ์—ญ์ง๋ ฌํ™”, ์–ธ๋งˆ์ƒฌ๋ง)์ด๋ผ๊ณ  ํ•œ๋‹ค. GPT ํ”ผ์…œ ) ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค ํŠธ๋žœ..