2017-06-21 8 views
0

私はJava Spark Project(Sparkバージョン1.6.1)でデータフレームを使用しています。 私はリファクタリングして、データセットを使用して、それらに付属の強力な型付きの機能を悪用しようとしています。純粋なSQLクエリを使用するためにデータセットを使用したRegisterTempTable Spark Java

dataframe.registerTempTable("table") 

:私は次のコードを使用していたプロジェクトの一部で 。

この種の機能はデータセットには存在しないように見えますが、私はそれに類似した方法を見つけることができません。

ご確認いただけますか?

答えて

0

使用createOrReplaceTempView

ます。public void createOrReplaceTempView(文字列たviewName)

は、指定された名前を使用してローカルの一時的なビューを作成します。この一時ビューの有効期間は、この>データセットの作成に使用されたSparkSessionに関連付けられています。

パラメータ:

たviewName - (文書化されていない)

以来:

2.0.0

+0

私はスパーク1.6.1を使用していますが、更新することができない、言ったように。 – Edge7

関連する問題