Load and write Cassandra tables
1 2 3 4 | spark_load_cassandra_table(sc, cass_keyspace, cass_tbl, spk_tbl_name,
partition_filter = FALSE, select_cols = FALSE, cache_table = FALSE)
spark_write_cassandra_table(spk_tbl, cass_keyspace, cass_tbl)
|
sc |
The spark context |
cass_keyspace |
A Cassandra keyspace |
cass_tbl |
A Cassandra table/column family |
spk_tbl_name |
The variable name of the loaded table in hive |
partition_filter |
A server-side filter clause |
select_cols |
A server-side select clause |
cache_table |
Do we load the table into memory? |
spk_tbl |
A handle to a hive table to write |
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.