Comment diffuser Sélectionnez les résultats (pas les résultats de la requête String) à partir de CassandraOperations?

Question

Spring Data Cassandra 1.5.0 est livré avec une API de streaming dans CassandraTemplate. J'utilise spring-data-cassandra 1.5.1. J'ai un code comme:

String tableName = cassandraTemplate.getTableName(MyEntity.class).toCql(); 
    Select select = QueryBuilder.select() 
      .all() 
      .from(tableName); 
    // In real world, WHERE statement is much more complex 
    select.where(eq(ENTITY_FIELD_NAME, expectedField)) 
    List<MyEntity> result = cassandraTemplate.select(select, MyEntity.class); 

et que vous souhaitez remplacer ce code avec itérables ou Java 8 flux afin d'éviter la récupération d'une grande liste de résultats à la mémoire à la fois. Ce que je cherche est une signature de méthode comme CassandraOperations.stream(Select query, Class<T> entityClass), mais elle n'est pas disponible.

La seule méthode disponible dans CassandraOperations accepte la chaîne de requête: stream(String query, Class<T> entityClass). J'ai essayé de passer ici une chaîne générée par Select comme

cassandraTemplate.stream(select.getQueryString(), MyEntity.class) 

Mais qui ne réussit pas avec InvalidQueryException: Invalid amount of bind variables, parce que getQueryString() retourne la requête avec des marques de positionnement question au lieu des variables.

Je vois 3 options pour obtenir ce que je veux, mais toutes les options semble mauvais:

• Utiliser le mécanisme de création de requêtes Spring avec le type de rendement attendu flux/Iterator (bien que pour les requêtes simples) http://docs.spring.io/spring-data/cassandra/docs/current/reference/html/#repositories.query-methods.query-creation
• d'utilisation requête CQL premières et de ne pas utiliser QueryBuilder
• Appel select.getQueryString() puis paramètres de substitution à nouveau par l'intermédiaire BoundStatement

Existe-t-il un meilleur moyen de diffuser les résultats de la sélection?

Merci.

Answer 1

Ainsi, dès maintenant la réponse à ma question est d'attendre que la version stable de spring-data-cassandra2.0.0 sort:

https://github.com/spring-projects/spring-data-cassandra/blob/2.0.x/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java#L208