[FLINK-26822] Add Source implementation for Cassandra connector

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: cassandra-3.1.0
• Component/s: Connectors / Cassandra
• Labels: pull-request-available
• Assignee: Etienne Chauchot
• Reporter: Martijn Visser
• Created: 23/Mar/22 08:15
• Updated: 22/Mar/23 08:38
• Resolved: 22/Mar/23 08:38

Description

The Cassandra connector is currently only available as a Sink implementation for DataStream users. We should also make it available as a Source. This should be done via Flink's Source API. More details can be found in FLIP-27 https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface

Issue Links

• links to: GitHub Pull Request #3
• links to: GitHub Pull Request #21073