cassandra_tbl: Load and write Cassandra tables

Description Usage Arguments

Description

Load and write Cassandra tables

Usage

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)

Arguments

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


AkhilNairAmey/crassy documentation built on May 5, 2019, 1:35 p.m.