question

Hi Team , We are using Asta DB and Java Casssandra java driver 4.13 to connect .

We are running spring boot http server with 2 GB memory depolyed in pivotal cloud having 16 Core CPU. On doing 10 parallel call we had observed high cup usage on s0-io threads and it results in overall cpu spike .

The CQL query is hitting partion key and fetching 250 rows each having 25 columns.

CompletionStage<AsyncResultSet> stage = cqlSession.executeAsync(bound);
    return stage.thenComposeAsync(RowCollector::new)
            .thenApplyAsync(rows -> rows.stream()
                .map(ItemInventory::new)
                .filter(filter)
                .collect(Collectors.toList()));

private static class RowCollector extends CompletableFuture<List<Row>> {
  final List<Row> rows = new ArrayList<>();
  RowCollector(AsyncResultSet first) {
    super();
    consumePage(first);
  }
  void consumePage(AsyncResultSet page) {
    for (Row row : page.currentPage()) {
      rows.add(row);
    }
    if (page.hasMorePages()) {
      page.fetchNextPage().thenAccept(this::consumePage);
    } else {
      complete(rows);
    }
  }
}