Alexander Dejanovski created BEAM-4049:
------------------------------------------
Summary: Improve write throughput of CassandraIO
Key: BEAM-4049
URL: https://issues.apache.org/jira/browse/BEAM-4049
Project: Beam
Issue Type: Improvement
Components: io-java-cassandra
Affects Versions: 2.4.0
Reporter: Alexander Dejanovski
Assignee: Jean-Baptiste Onofré
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
