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)