Scala: jak uruchomić komendę shell z poziomu kodu?

Aby wykonać komendę shell należy zaimportować bibliotekę scala.sys.process a następnie skorzystać z dostępnego Domain Specific Language (DSL) zdefiniowanego znakiem wykrzyknika (!).

# Zaimportuj bibliotekę
import scala.sys.process._

# Uruchom komendę shell
# W tym przypadku utworzymy katalog na HDFS
val targetPath = "/bigdataetl/data"
s"hdfs dfs -mkdir -p ${targetPath}" !

 

Apache Spark

Używając Apache Spark i pisząc w Scali może się okazać, że będziesz potrzebował również wykonać jakąś operację na plikach lub katalogach. Jak najbardziej możesz wtedy również skorzystać z powyższej biblioteki.

# Usunięcie pliku z HDFS
s"hdfs dfs -rm /bigdata_etl/temp_file.dat" !

 

Jeśli spodobał Ci się ten post to napisz proszę komentarz poniżej oraz udostępnij ten post na swoim Facebook’u, Twitter’ze, LinkedIn lub innej stronie z mediami społecznościowymi.
Z góry dzięki!

Please follow and like us:
error

Dodaj komentarz

Close Menu
Social media & sharing icons powered by UltimatelySocial
error

Enjoy this blog? Please spread the word :)