Apache Sparkでスケーラを使用してシェルファイルを実行する方法

Question

コードの末尾にscalaを使用してsparkを実行する必要があります。私は自分のコードでcountとgroupbyの関数を使いました。私は言及する必要があります、私のコードは、コードの最後の行なしで完全に動作します。

(import sys.process._ 
/////////////////////////linux commands 
val procresult="./Users/saeedtkh/Desktop/seprator.sh".!!) 

どうすれば解決するのか教えてください。

Answer 1

あなたはScalaのSDKからsys.process._パッケージを使用して!でDSLを使用する必要があります。

import sys.process._ 
val result = "ls -al".! 

それともscala.sys.process.Processと同じ作りを：

import scala.sys.process._ 
Process("cat data.txt")! 

Answer 2

ほとんどあります。 を追加する必要があります。 command.For例の最後に：私は、配列を使用

import sys.process._ 
val a = Seq("sh", "-c", " cal ").!! 
println(a) 

理由は、あなたが渡すパラメータの詳細な制御を持っているということです。 この記事を参照してください。How to execute shell builtin from Scala