Alexander Dejanovski created BEAM-4049:

             Summary: Improve write throughput of CassandraIO
                 Key: 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 

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 

This message was sent by Atlassian JIRA

Reply via email to