今後のメソッドを使用するScala_Spark_DataFrame

HiveContextをScalaを使用してFutureと読んでいるシナリオを解決する必要があります。しかし、返されたデータフレームは印刷できません。今後のメソッドを使用するScala_Spark_DataFrame

マイコード：Future[DataFrame]オブジェクトからDataFrameを取得する方法を

val f: Future[DataFrame] = Future{hive.sql("select * from test1.emp")}

？

リンクをありがとうございます。しかし、このデータフレームはここにあります。私はいつもデータフレームではなくo/pとしてスキーマを得ています –

'f.onComplete {case Success（v）=> v.show}' – philantrovert

ありがとうございました。 –

として簡単なので、基本的にはすでにここに掲載の回答のように

val f: Future[DataFrame] = Future{hive.sql("select * from test1.emp")}.foreach(df => df.show())

として - Getting data out of a Future in Scala、マップ機能のデータフレーム上のすべてのあなたの操作を行うことができます。 df.show()は、他のコマンドで置き換えることができます。

2017-11-15 10:17:44 Niemand

この場合、エラーの種類の不一致がエラーとして表示されます。-Found：unit but required：Dataframe –

私の悪い点は、機能が単なる印刷物であれば、マップのforeach isnteadにする必要があります。 – Niemand

答えて