. okuma içinSparkSQL SQL sorgusu JDBC tablosuna yazılacak nedir? Spark'deki SQL sorgusu için
, biz yazma için
CREATE TEMPORARY TABLE jdbcTable
USING org.apache.spark.sql.jdbc
OPTIONS dbtable ...;
tarafından jdbc okuyabilir, SQL kullanarak uzaktan JDBC tabloya veri yazmak için sorgu nedir?
NOT: SQL sorgusu olmasını istiyorum. plz, SparkSQL'in HiveContext.sql (...) öğesini kullanırken jdbc'ye yazabilen salt "SQL sorgusu" sağlar.
Veritabanını aşağıdaki gibi jdbc ile yazabilirsiniz.
df.write.jdbc(url, "TEST.BASICCREATETEST", new Properties)
Evet, yapabilirsiniz. Varolan bir tabloya bir dataframe kaydetmek istiyorsanız
df.insertIntoJDBC(url, table, overwrite)
kullanabilir ve bu dataframe kurtarmak için yeni bir tablo oluşturmak istiyorsanız, size
df.createJDBCTable(url, table, allowExisting)
// sc is an existing SparkContext.
val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)
sqlContext.sql("CREATE TABLE IF NOT EXISTS src (key INT, value STRING)")
sqlContext.sql("LOAD DATA LOCAL INPATH 'examples/src/main/resources/kv1.txt' INTO TABLE src")