02_λΉ λ°μ΄ν° κΈ°μ λ° μ λ(5)-νλ‘/μνμΉμ€νν¬/맡리λμ€
β’νλ‘(Hadoop)
λΆμ° μ²λ¦¬ νκ²½μμ λμ©λ λ°μ΄ν° μ²λ¦¬ λ° λΆμμ μ§μνλ μ€νμμ€ μννΈμ¨μ΄ νλ μμν¬μ΄λ€.
β μΌνμμ μ΅μ΄λ‘ κ°λ°νμΌλ©°, μ§κΈμ μνμΉ μννΈμ¨μ΄ μ¬λ¨μμ νλ‘μ νΈλ‘ κ΄λ¦¬λκ³ μλ€.
β νλ‘ λΆμ°νμΌμμ€ν μΈ HDFSμ λΆμ°μΉΌλΌκΈ°λ° λ°μ΄ν°λ² μ΄μ€μΈ Hbase, λΆμ° μ»΄ν¨ν μ§μ νλ μμν¬μΈ 맡리λμ€(MapReduce)λ‘ κ΅¬μ±λμ΄ μλ€.
β λΆμ°νμΌμμ€ν μ ν΅ν΄ μ μ²λμ μ₯λΉμ λμ©λ νμΌμ λλμ΄ μ μ₯ν μ μλ κΈ°λ₯μ μ 곡νλ€.
γΌλΆμ°νμΌμμ€ν μ μ μ₯λ λμ©λμ λ°μ΄ν°λ€μ 맡리λμ€λ₯Ό μ΄μ©νμ¬ μ€μκ°μΌλ‘ μ²λ¦¬ λ° λΆμ κ°λ₯νλ€.
β νλ‘μ λΆμ‘±ν κΈ°λ₯μ 보μνλ νλ‘ μμ½μμ€ν μ΄ λ±μ₯νμ¬ λ€μν μ루μ μ μ 곡νλ€.
β£ μνμΉ μ€νν¬(Apache Spark)
μ€μκ° λΆμ°ν μ»΄ν¨ν νλ«νΌμΌλ‘ In-Memory λ°©μμΌλ‘ μ²λ¦¬λ₯Ό νλ©° νλ‘λ³΄λ€ μ²λ¦¬μλκ° λΉ λ₯΄λ€.
β μ€μΉΌλΌ μΈμ΄λ‘ κ°λ°λμμ§λ§ μ€μΉΌλΌλΏλ§ μλλΌ Java, R, Pythonμ μ§μνλ€.
†맡리λμ€(MapReduce)
ꡬκΈμμ κ°λ°ν λ°©λν μμ λ°μ΄ν°λ₯Ό μ μνκ² μ²λ¦¬νλ νλ‘κ·Έλλ° λͺ¨λΈλ‘ ν¨κ³Όμ μΈ λ³λ ¬ λ° λΆμ° μ²λ¦¬λ₯Ό μ§μνλ€.
β λ°νμ(Runtime)μμμ μ λ ₯ λ°μ΄ν° λΆν , μμ μ€μΌμ€λ§, λ Έλ κ³ μ₯, λ Έλκ°μ λ°μ΄ν° μ μ‘ μμ μ΄ λ§΅λ¦¬λμ€ μ²λ¦¬ μ±λ₯μ λ§μ μν₯μ λ―ΈμΉλ€.
βΆλ§΅λ¦¬λμ€ μ²λ¦¬λ¨κ³
| 1λ¨κ³ | μ λ ₯ λ°μ΄ν°λ₯Ό μ½κ³ λΆν νλ€. |
| 2λ¨κ³ | λΆν λ λ°μ΄ν°λ₯Ό ν λΉν΄ λ§΅ μμ μ μνν ν, κ·Έ κ²°κ³ΌμΈ μ€κ° λ°μ΄ν°λ₯Ό ν΅ν© λ° μ¬λΆν νλ€. |
| 3λ¨κ³ | ν΅ν© λ° μ¬λΆν λ μ€κ° λ°μ΄ν°λ₯Ό μ ν(Shuffle)νλ€. |
| 4λ¨κ³ | μ νλ μ€κ° λ°μ΄ν°λ₯Ό μ΄μ©ν΄ 리λμ€ μμ μ μννλ€. |
| 5λ¨κ³ | μΆλ ₯ λ°μ΄ν°λ₯Ό μμ±νκ³ , 맡리λμ€ μ²λ¦¬λ₯Ό μ’ λ£νλ€. |