HI All, does anyone have an example of using CassandraIO to query a table?
The following mentions "Alternatively, one may use CassandraIO.<Person>readAll() .withCoder(SerializableCoder.of(Person.class)) to query a subset of the Cassandra database by creating a PCollection of CassandraIO.Read<Person> each with their own query or RingRange." https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/cassandra/CassandraIO.html Hoping there would be an example of this. TIA, Adam
