7
Sto usando Spark 1.3 e desidero unirmi su più colonne utilizzando l'interfaccia python (SparkSQL)SparkSQL uniscono sulla colonna multipla
le seguenti opere:
ho registrarli come tabelle temporanee.
numeric.registerTempTable("numeric")
Ref.registerTempTable("Ref")
test = numeric.join(Ref, numeric.ID == Ref.ID, joinType='inner')
Vorrei ora unirmi in base a più colonne.
ottengo SyntaxError
: sintassi non valida con questo:
test = numeric.join(Ref,
numeric.ID == Ref.ID AND numeric.TYPE == Ref.TYPE AND
numeric.STATUS == Ref.STATUS , joinType='inner')