There are some examples in the test code that should be easy enough to follow.
Here is an example of just querying the entire table: https://github.com/apache/beam/blob/master/sdks/java/io/cassandra/src/test/java/org/apache/beam/sdk/io/cassandra/CassandraIOTest.java#L460 Here's an example of using readAll to only pull certain keys: https://github.com/apache/beam/blob/master/sdks/java/io/cassandra/src/test/java/org/apache/beam/sdk/io/cassandra/CassandraIOTest.java#L381 *~Vincent* On Fri, Feb 3, 2023 at 12:59 PM Adam Scott <adam.c.sc...@gmail.com> wrote: > 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 > > > >
