[Bug]: CassandraIO creates bad query with ValueProvider query string

[georgecma]

What happened?

Check my PR for tests that check for this condition failing.

Steps to reproduce:

1. Create a ValueProvider that provides a String query into CassandraIO.read.withQuery(new someQueryValueProvider()); The ValueProvider can simply passthrough a query e.g. "SELECT * FROM KEYSPACE.TABLE";
2. Run CassandraIO Read
3. Note that CassandraIO fails.

The exact reason it fails is because CassandraIO read naively appends "AND" to all spec.query() values. In the reproduced steps, "SELECT * FROM KEYSPACE.TABLE" will change to "SELECT * FROM KEYSPACE.TABLE AND ..." which is invalid CQL syntax.

Issue Priority

Priority: 2 (default / most bugs should be filed as P2)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner

[georgecma]

.take-issue