Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val df = sqlContext.phoenixTableAsDataFrame(
- Metadata.tables(A.Test), Seq("ID", "date", "col1", "col2","col3"),
- predicate = Some(""date" = " + date), zkUrl = Some(zkURL))
- val df1 = df.groupBy($"ID", $"YEAR", $"MONTH", $"DAY").agg(
- sum($"col1" + $"col2" + $"col3").alias("col4"))
Add Comment
Please, Sign In to add comment
