distcp

Definition

HDFS์— ์ €์žฅ๋œ ํŒŒ์ผ์„ ๋‹ค๋ฅธ HDFS๋กœ ๋ณต์‚ฌํ•˜๋Š” ๋…ธ๋“œ์ด๋‹ค. ์ขŒ์ธก [Flow๊ตฌ์„ฑ]๋…ธ๋“œ ์ค‘ [distcp]๋…ธ๋“œ๋ฅผ drag & drop ํ•œ ํ›„ Property ํ•ญ๋ชฉ์„ ์ž…๋ ฅํ•œ๋‹ค. Property ํŒจ๋„์˜ [๋”๋ณด๊ธฐ+] ๋ฒ„ํŠผ์„ ๋ˆ„๋ฅด๋ฉด ์ž…๋ ฅ๊ฐ€๋Šฅํ•œ ์ „์ฒด Property ํ•ญ๋ชฉ์„ ๋ณผ ์ˆ˜ ์žˆ๋‹ค.

Set

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

property

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

flow003

  1. retry : max: ์žฌ์ˆ˜ํ–‰ ํšŸ ์ˆ˜ : period: ์žฌ์ˆ˜ํ–‰ ๊ฐ„๊ฒฉ
  2. argument : ์ฒซ๋ฒˆ์žฌ arg ๊ฒฝ๋กœ๋ฅผ 2,3,4,โ€ฆ,n ๊ฒฝ๋กœ๋กœ ๋ณต์‚ฌํ•œ๋‹ค.
  3. forceOK : ์‹คํŒจ ์‹œ ๊ฐ•์ œ OK ์ฒ˜๋ฆฌ ์—ฌ๋ถ€

Example

kbtest ํด๋Ÿฌ์Šคํ„ฐ์˜ HR_Retention.csvํŒŒ์ผ์„ test1234 ํด๋Ÿฌ์Šคํ„ฐ์— [distcp] ๋…ธ๋“œ๋ฅผ ์‚ฌ์šฉํ•˜์—ฌ ๋ณต์‚ฌํ•œ๋‹ค.

  1. ์ฒซ ๋ฒˆ์งธ arg์— HR_Retention.csvํŒŒ์ผ์ด ์ €์žฅ๋œ path๋ฅผ, ๋‘ ๋ฒˆ์งธ arg์— target path๋ฅผ ์ž…๋ ฅํ•œ๋‹ค.
  • source : hdfs://kbtest-accu-hdfs-nn.suka:9000/tmp/test
  • target : hdfs://test1234-accu-hdfs-nn.suka:9000/tmp

flow050

  1. distcp ์›Œํฌํ”Œ๋กœ์šฐ ์‹คํ–‰ ํ›„ test1234 ํด๋Ÿฌ์Šคํ„ฐ์— ./test/HR_retention.csvํŒŒ์ผ์ด ์ƒ์„ฑ๋˜์—ˆ๋‹ค.

flow051