[BEAM-4049] Improve write throughput of CassandraIO

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.4.0
• Fix Version/s: 2.5.0
• Component/s: io-java-cassandra
• Labels: performance
• Assignee: Alexander Dejanovski
• Reporter: Alexander Dejanovski
• Created: 11/Apr/18 10:01
• Updated: 16/May/20 13:52
• Resolved: 23/Apr/18 08:43

Description

The CassandraIO currently uses the mapper to perform writes in a synchronous fashion. 

This implies that writes are serialized and is a very suboptimal way of writing to Cassandra.

The IO should use the saveAsync() method instead of save() and should wait for completion each time 100 queries are in flight, in order to avoid overwhelming clusters.

Issue Links

• is caused by: BEAM-5723 CassandraIO is broken because of use of bad relocation of guava
• is caused by: BEAM-6972 LTS backport: CassandraIO is broken because of use of bad relocation of guava
• links to: GitHub Pull Request #5112