Erstellen Sie eine "temporäre" Tabelle in Spark-SQL, nicht Spark-Scala?

Question

Ich habe eine Tabelle aus einer Eingabedatei geladen.

CREATE TABLE MyTable (
    ID INT, 
    VALUE FLOAT, 
    RATE INT 
... 

LOAD DATA LOCAL INPATH 'MYPATH' INTO TABLE MyTable; 

Nun würde Ich mag einen neuen erstellen auf dieser Basis ein

DerivedTable = 
    SELECT ID, VALUE*RATE AS Total 
    FROM MyTable 
    WHERE VALUE IS NOT NULL; 

dann für andere Tabellen und für Ausgänge Ich werde diese Tabelle als Quelle verwenden.

Was ist ein richtiger Sql (oder Hive) Weg, um diese "temporäre" Tabelle zu erstellen? Dies sollte in spark-sql funktionieren?

PS: Ich weiß, wie man das in Spark-Shell macht. Aber das ist nicht das, wonach ich suche.

Answer 1

Sie können:

CREATE TEMPORARY VIEW DerivedTable AS (
    SELECT ID, VALUE*RATE AS Total 
    FROM MyTable 
    WHERE VALUE IS NOT NULL);