Skip to content

Commit

Permalink
apply review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
jacek-lewandowski committed May 29, 2024
1 parent fea2355 commit 3316258
Showing 1 changed file with 12 additions and 0 deletions.
12 changes: 12 additions & 0 deletions doc/14_data_frames.md
Original file line number Diff line number Diff line change
Expand Up @@ -160,18 +160,30 @@ 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
```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
Expand Down

0 comments on commit 3316258

Please sign in to comment.