diff --git a/doc/14_data_frames.md b/doc/14_data_frames.md index 564c66ec0..aa97ccecd 100644 --- a/doc/14_data_frames.md +++ b/doc/14_data_frames.md @@ -160,6 +160,12 @@ Reading with Scala spark.read.table("casscatalog.ksname.testTable") ``` +Reading vectors, specifying a predicate on vector column +```sql +SELECT name, features FROM casscatalog.test.things WHERE features = array(float(1), float(1.5), float(4)) +``` + + #### Writing Examples Writing with Sql @@ -167,11 +173,17 @@ Writing with Sql INSERT INTO casscatalog.ksname.testTable SELECT * from casscatalog.ksname.testTable2 ``` + Writing with Scala ```scala df.writeTo("casscatalog.ksname.testTable") ``` +Writing vectors +```sql +INSERT INTO casscatalog.test.things (id, name, features) VALUES (9, 'x', array(2, 3, 4)) +``` + #### Predicate Pushdown and Column Pruning The connector will automatically pushdown all valid predicates to Cassandra. The