Bạn có thể làm tương tự với Scala. Sử dụng JDBC (java.sql.{Connection,DriverManager}
) và nhận tập hợp kết quả.
Bạn không thể, bởi vì đây không phải là một truy vấn Postgres. Những gì bạn thực thi trong spark.sql
là một truy vấn Spark. Những gì bạn có thể làm là sử dụng truy vấn con:
- Trong Apache Spark 2.0.0, có thể tìm nạp truy vấn từ cơ sở dữ liệu bên ngoài không (thay vì lấy toàn bộ bảng)?
- Cách sử dụng truy vấn SQL để xác định bảng trong dbtable?
Có thể nó sẽ phù hợp với yêu cầu của bạn (nếu truy vấn không cần phải động). Thật không may, Spark SQL cũng không hỗ trợ các kiểu hình học, do đó, Spark có thể phải chuyển nó thành thứ gì đó có thể tiêu thụ được bởi Spark hoặc xác định phương ngữ của riêng bạn.