select

Definition

ํ•„์š” ์ปฌ๋Ÿผ๋งŒ ์„ ํƒํ•˜์—ฌ ์กฐํšŒํ•˜๋Š” ๋…ธ๋“œ์ด๋‹ค. ์ปฌ๋Ÿผ ์„ ํƒ ์ˆœ์„œ์— ๋”ฐ๋ผ ๋…ธ์ถœ ์ˆœ์„œ๊ฐ€ ์ ์šฉ๋œ๋‹ค. ํŒ์—…๊ธฐ๋Šฅ์„ ์ œ๊ณตํ•˜๋ฏ€๋กœ ๋…ธ์ถœ์ˆœ์„œ๋ฅผ ํ™•์ธํ•  ์ˆ˜ ์žˆ๋‹ค. ์ขŒ์ธก [๋ฐ์ดํ„ฐ์ฒ˜๋ฆฌ(๊ธฐ๋ณธ)]๋…ธ๋“œ ์ค‘ [select]๋…ธ๋“œ๋ฅผ drag & drop ํ•œ ํ›„ Property ํ•ญ๋ชฉ์„ ์ž…๋ ฅํ•œ๋‹ค.

Set

[setting], [scheduler], [parameter] ์„ค์ •์€ [์›Œํฌํ”Œ๋กœ์šฐ ์ƒ์„ฑ] > [์„ค์ •]์„ ์ฐธ๊ณ ํ•œ๋‹ค.

property

[Node Description] ์ž‘์„ฑ ์ค‘์ธ ๋…ธ๋“œ๋ช… ์ž…๋ ฅ

  1. col : ์ ์šฉํ•  column ์„ ํƒ. ์•„๋ž˜ 2๊ฐ€์ง€ ๋ฐฉ๋ฒ• ์ง€์›
    • ์šฐ์ธก ์ˆ˜์ •๋ฒ„ํŠผ ํ™œ์šฉํ•˜์—ฌ ํ•„์š” ์ปฌ๋Ÿผ ์„ ํƒ
    • ๋“œ๋กญ๋‹ค์šด ๋ฒ„ํŠผ์—์„œ ํ•„์š” ์ปฌ๋Ÿผ ์„ ํƒ

Example

Sample ๋ฐ์ดํ„ฐ๋กœ ์‚ฌ์šฉ์ค‘์ธ ์ƒํ’ˆ์ •๋ณด์—์„œ ํ•„์š”ํ•œ ์ปฌ๋Ÿผ(goods_id, category, price, shop_id)๋งŒ ์„ ํƒํ•˜๋Š” ์›Œํฌํ”Œ๋กœ์šฐ๋ฅผ ์ž‘์„ฑํ•œ๋‹ค(์‹คํ–‰ํด๋Ÿฌ์Šคํ„ฐ : kbtest).

  1. hdfs์— ์ ์žฌ๋œ ํŒŒ์ผ(goods-sample2.csv)์„ [HDFS๋ถˆ๋Ÿฌ์˜ค๊ธฐ]๋กœ ๋ถˆ๋Ÿฌ์˜จ๋‹ค. ์ž…๋ ฅ์ •๋ณด๋Š” ์•„๋ž˜์™€ ๊ฐ™๋‹ค.

    propertyinput data
    1.filehdfs://kbtest-accu-hdfs-nn.suka:9000/tmp/goods-sample2.csv
    2.formatcsv
    3.delimiter,
    4.sampling100%
    11.schema์ž๋™ํŒŒ์‹ฑ

    prebasic054

  2. [HDFS๋ถˆ๋Ÿฌ์˜ค๊ธฐ] ์ž‘์—…์—์„œ ๋งŒ๋“ค์–ด์ง„ ETL ๋…ธ๋“œ ๋‚ด๋ถ€์— [select]๋…ธ๋“œ๋ฅผ drag & drop ํ•œ ํ›„ ๋‘ ๋…ธ๋“œ๋ฅผ ์—ฐ๊ฒฐํ•œ๋‹ค.

prebasic055

  1. [select]๋…ธ๋“œ "1.col" property์—์„œ ๋“œ๋กญ๋‹ค์šด ๋ฒ„ํŠผ์„ ๋ˆŒ๋Ÿฌ ํ•„์š”ํ•œ ์ปฌ๋Ÿผ์„ ์„ ํƒํ•œ๋‹ค(์šฐ์ธก [์ˆ˜์ •] ๋ฒ„ํŠผ ํด๋ฆญ ํ›„ ์„ ํƒํ•ด๋„ ๋ฌด๋ฐฉ).

prebasic056

  1. select ๋…ธ๋“œ์—์„œ ์Šค๋ƒ…์ƒท์ •๋ณด์™€ ์Šคํ‚ค๋งˆ์ •๋ณด๋ฅผ ํ™•์ธํ•œ๋‹ค.

    • ์Šค๋ƒ…์ƒท ์ •๋ณด
      prebasic057

    • ๋…ธ๋“œ ์Šคํ‚ค๋งˆ ์ •๋ณด
      prebasic058

Troubleshooting

  1. ํด๋Ÿฌ์Šคํ„ฐ [OOO]์˜ ์„ธ์…˜์ƒํƒœ๋ฅผ ํ™•์ธํ•  ์ˆ˜ ์—†์Šต๋‹ˆ๋‹ค.(์„ค์ • > ์„ธ์…˜๊ด€๋ฆฌ)

prebasic059

Apache Livy ์„ธ์…˜์ด ์ข…๋ฃŒ๋๊ฑฐ๋‚˜, ํด๋Ÿฌ์Šคํ„ฐ ๋‚ด ๊ฐ€์šฉ Memory๋ฅผ ๋‹ค์ˆ˜ ์ ์œ ํ•˜๊ณ  ์žˆ์–ด ์›Œํฌํ”Œ๋กœ์šฐ ์‹คํ–‰์ด ์–ด๋ ค์šธ ๊ฒฝ์šฐ ์œ„์™€ ๊ฐ™์€ ๋ฉ”์‹œ์ง€๊ฐ€ ๋‚˜ํƒ€๋‚  ์ˆ˜ ์žˆ๋‹ค. ์•„๋ž˜์™€ ๊ฐ™์ด ์กฐ์น˜ํ•œ๋‹ค.

1> [์„ค์ •] > [์„ธ์…˜๊ด€๋ฆฌ]์—์„œ ์„ธ์…˜ ์ƒํƒœ์ •๋ณด๋ฅผ ํ™•์ธํ•œ๋‹ค. [NONE], [DEAD] ์ƒํƒœ์ผ ๊ฒฝ์šฐ ๊ธฐ๋Šฅ ํ•„๋“œ์—์„œ [์„ธ์…˜์ƒ์„ฑ] ๋ฒ„ํŠผ์„ ๋ˆŒ๋Ÿฌ Livy Seseeion์„ ์ƒ์„ฑํ•œ๋‹ค.

2> ์ƒํƒœ์ •๋ณด๊ฐ€ [IDLE]์ผ ๊ฒฝ์šฐ Livy Session์€ ๋–  ์žˆ์œผ๋‚˜, ํ˜„์žฌ ์ž‘์—…์ค‘ ๋˜๋Š” ์ž‘์—…์™„๋ฃŒ ํ›„ ๋ฉ”๋ชจ๋ฆฌ๋ฅผ ๋ฐ˜ํ™˜ํ•˜์ง€ ์•Š์€ ์ƒํƒœ์ด๋‹ค. ์•„๋ž˜์™€ ๊ฐ™์ด ์ž‘์—…์ƒํƒœ๋ฅผ ๋จผ์ € ํ™•์ธํ•œ๋‹ค.

  • [DHP] > [CLUSTER] > ์ž‘์—… ํด๋Ÿฌ์Šคํ„ฐ๋ช… > [APPL HISTORY] ์œผ๋กœ ์ด๋™ ํ›„ ID๋ณ„ ์ž‘์—…์ƒํƒœ(State, Final State)์ •๋ณด๋ฅผ ํ™•์ธํ•œ๋‹ค.
  • "bpSession"์„ ์ œ์™ธํ•œ ๋‹ค๋ฅธ ์ž‘์—…๋“ค์ด ์ข…๋ฃŒ์ƒํƒœ๋ผ๋ฉด [์„ธ์…˜๊ด€๋ฆฌ]์—์„œ [์„ธ์…˜์‚ญ์ œ] ํ›„ [์„ธ์…˜์ƒ์„ฑ] ์ž‘์—…์„ ์ˆ˜ํ–‰ํ•œ๋‹ค.