1

Spark にキャッシュされたハイブ テーブル ("person") があります。

sqlContext.sql("create table person (name string, age int)") //Create a new table
//Add some values to the table
...
...
//Cache the table in Spark
sqlContext.cacheTable("person") 
sqlContext.isCached("person") //Returns true
sqlContext.sql("insert into table person values ("Foo", 25)") // Insert some other value in the table

//Check caching status again
sqlContext.isCached("person") //Returns true

sqlContext はHiveContextです。

cacheTable("person")ステートメントの後に挿入されたエントリはキャッシュされますか? つまり、("Foo", 25) エントリが Spark にキャッシュされているかどうか。

そうでない場合、後で挿入されたエントリのみをキャッシュするにはどうすればよいですか? 最初にキャッシュを解除してから、テーブル全体を再度キャッシュしたくありません。

4

0 に答える 0