๋ฐ˜์‘ํ˜•
spark ์ž‘์—…๊ด€๋ฆฌ

 

Apache Livy๋Š” REST ์ธํ„ฐํŽ˜์ด์Šค๋ฅผ ํ†ตํ•ด Spark ํด๋Ÿฌ์Šคํ„ฐ์™€ ์‰ฝ๊ฒŒ ์ƒํ˜ธ ์ž‘์šฉํ•  ์ˆ˜ ์žˆ๋Š” ์„œ๋น„์Šค์ž…๋‹ˆ๋‹ค. ๊ฐ„๋‹จํ•œ REST ์ธํ„ฐํŽ˜์ด์Šค ๋˜๋Š” RPC ํด๋ผ์ด์–ธํŠธ ๋ผ์ด๋ธŒ๋Ÿฌ๋ฆฌ๋ฅผ ํ†ตํ•ด Spark ์ž‘์—… ๋˜๋Š” Spark ์ฝ”๋“œ ์Šค๋‹ˆํŽซ, ๋™๊ธฐ ๋˜๋Š” ๋น„๋™๊ธฐ ๊ฒฐ๊ณผ ๊ฒ€์ƒ‰, Spark ์ปจํ…์ŠคํŠธ ๊ด€๋ฆฌ๋ฅผ ์‰ฝ๊ฒŒ ์ œ์ถœํ•  ์ˆ˜ ์žˆ์Šต๋‹ˆ๋‹ค. ๋˜ํ•œ Apache Livy๋Š” Spark์™€ ์• ํ”Œ๋ฆฌ์ผ€์ด์…˜ ์„œ๋ฒ„ ๊ฐ„์˜ ์ƒํ˜ธ ์ž‘์šฉ์„ ๋‹จ์ˆœํ™”ํ•˜์—ฌ ๋Œ€ํ™”ํ˜• ์›น/๋ชจ๋ฐ”์ผ ์• ํ”Œ๋ฆฌ์ผ€์ด์…˜์— Spark๋ฅผ ์‚ฌ์šฉํ•  ์ˆ˜ ์žˆ๋„๋ก ํ•ฉ๋‹ˆ๋‹ค. ์ถ”๊ฐ€ ๊ธฐ๋Šฅ์€ ๋‹ค์Œ๊ณผ ๊ฐ™์Šต๋‹ˆ๋‹ค.

  • ์—ฌ๋Ÿฌ ํด๋ผ์ด์–ธํŠธ์—์„œ ์—ฌ๋Ÿฌ Spark ์ž‘์—…์— ์‚ฌ์šฉํ•  ์ˆ˜ ์žˆ๋Š” ์žฅ๊ธฐ ์‹คํ–‰ Spark ์ปจํ…์ŠคํŠธ ๋ณด์œ 
  • ์—ฌ๋Ÿฌ ์ž‘์—… ๋ฐ ํด๋ผ์ด์–ธํŠธ์—์„œ ์บ์‹œ๋œ RDD ๋˜๋Š” ๋ฐ์ดํ„ฐ ํ”„๋ ˆ์ž„ ๊ณต์œ 
  • ์—ฌ๋Ÿฌ Spark Context๋ฅผ ๋™์‹œ์— ๊ด€๋ฆฌํ•  ์ˆ˜ ์žˆ์œผ๋ฉฐ, ์šฐ์ˆ˜ํ•œ ๋‚ด๊ฒฐํ•จ์„ฑ๊ณผ ๋™์‹œ์„ฑ์„ ์œ„ํ•ด Livy Server ๋Œ€์‹  ํด๋Ÿฌ์Šคํ„ฐ(YARN/Mesos)์—์„œ Spark Context๋ฅผ ์‹คํ–‰ํ•ฉ๋‹ˆ๋‹ค.
  • ์ž‘์—…์€ ๋ฏธ๋ฆฌ ์ปดํŒŒ์ผ๋œ jar, ์ฝ”๋“œ ์กฐ๊ฐ ๋˜๋Š” java/scala ํด๋ผ์ด์–ธํŠธ API๋ฅผ ํ†ตํ•ด ์ œ์ถœํ•  ์ˆ˜ ์žˆ์Šต๋‹ˆ๋‹ค.
  • ๋ณด์•ˆ ์ธ์ฆ ํ†ต์‹ ์„ ํ†ตํ•œ ๋ณด์•ˆ ํ™•๋ณด

 

728x90
๋ฐ˜์‘ํ˜•

+ Recent posts