Advertisement
Guest User

Untitled

a guest
Oct 26th, 2016
223
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
SPARK 0.20 KB | None | 0 0
  1. val functionSome = udf((someName: String) => {
  2.     otherDF.filter(otherDF("name") === someName).count
  3. })
  4.  
  5. someDF = someDF.withColumn("newColumn", functionSome(someDF("someName")))
  6.  
  7. someDF.show()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement