관리 메뉴

data_lab

Spark Session λ³Έλ¬Έ

SPARK/[λŸ¬λ‹ 슀파크]

Spark Session

🐰히히 2023. 1. 19. 15:41

슀파크 μ„Έμ…˜ 생성

val spark = SparkSession
    .appName("Spark Session")
    .config("config.name",congfig.value")
    .getOrCreate()

 

 

슀파크 μ• ν”Œλ¦¬μΌ€μ΄μ…˜ -> 슀파크 λ“œλΌμ΄λ²„ ν”„λ‘œκ·Έλž¨ -> 슀파크 μ„Έμ…˜ 객체

 

슀파크 λ“œλΌμ΄λ²„λŠ” 슀파크 μ• ν”Œλ¦¬μΌ€μ΄μ…˜μ„ ν•˜λ‚˜μ΄μƒμ˜ 작으둜 λ³€ν™˜ 

μž‘μ—λŠ” 연산이 μ—¬λŸ¬κ°œμ˜ 슀파크 μŠ€ν…Œμ΄μ§€λ‘œ λ‚˜λ‰¨

각 μŠ€ν…Œμ΄μ§€λŠ” μ΅œμ†Œ μ‹€ν–‰ λ‹¨μœ„μ΄λ©° μ—°ν•© μ‹€ν–‰λ˜λŠ” 슀파크 νƒœμŠ€ν¬λ“€λ‘œ 이루어짐

 

728x90
λ°˜μ‘ν˜•