cassandra - PlayOrm を使用してクエリを読み取ると、適切な結果が返されます

Question

私は PlayOrm の調査を開始し、ネット上で利用可能な基本的なコードを実行してデータを挿入および読み取りしようとしました。データを挿入すると、すべて正常に動作しているように見えますが、同じデータを読み取ると、間違った行数が返されます。たとえば。3 つのレコードを挿入すると、レコードが 0 になることもあれば、すべてのレコードが返されることもあります。

私が使用しているコードに従ってください：

データの挿入/読み取りに使用されるクラス:

  @NoSqlEntity
  @NoSqlQueries({
    @NoSqlQuery(name="findByLastName", query="PARTITIONS t('lastName',:lastName) select *  FROM TABLE as t"),
    @NoSqlQuery(name="findByName", query="PARTITIONS e('name',:name) select *  FROM TABLE as e")
  })

  public class User {

    @NoSqlId
    private String id;

    @NoSqlPartitionByThisField
    private String name;

    @NoSqlIndexed
    private int age;

    @NoSqlPartitionByThisField
    @NoSqlIndexed
    private String lastName;

    public String getId() {
            return id;
    }

    public void setId(String id) {
            this.id = id;
    }

    public int getAge() {
            return age;
    }

    public void setAge(int age) {
            this.age = age;
    }

    public String getName() {
            return name;
    }

    public void setName(String name) {
            this.name = name;
    }

    public String getLastName() {
            return lastName;
    }

    public void setLastName(String lastName) {
            this.lastName = lastName;
    }
    /*
     * Queries:
     *      @NoSqlQuery(name="findByLastName", query="PARTITIONS t('lastName',:lastName) select *  FROM TABLE as t"),
     *      @NoSqlQuery(name="findByName", query="PARTITIONS e('name',:name) select *  FROM TABLE as e")
     */

    public static List<User> findByLastName(NoSqlEntityManager mgr, String lastName) {
            Query<User> query = mgr.createNamedQuery(User.class, "findByLastName");
            System.out.println("Using last name "+lastName);
            query.setParameter("lastName", lastName);
            return query.getResultList(0, 100);
    }

    public static List<User> findByName(NoSqlEntityManager mgr, String name) {
            Query<User> query = mgr.createNamedQuery(User.class, "findByName");
            System.out.println("Using name "+name);
            query.setParameter("name", name);
            return query.getResultList(0, 100);
    }

  }

このクラスを利用するコード:

import java.awt.List;
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Map;
import com.alvazan.orm.api.base.Bootstrap;
import com.alvazan.orm.api.base.DbTypeEnum;
import com.alvazan.orm.api.base.NoSqlEntityManager;
import com.alvazan.orm.api.base.NoSqlEntityManagerFactory;
import com.netflix.astyanax.retry.SleepingRetryPolicy;

public class Example {

private static NoSqlEntityManager mgr;
public static void main(String[] args) {
    Map<String, Object> properties = new HashMap<String, Object>();
    properties.put(Bootstrap.AUTO_CREATE_KEY, "create");
    /*
     * Bootstrap.createAndAddBestCassandraConfiguration(properties, clusterName, keyspace, seeds);
     * NoSqlEntityManagerFactory factory = Bootstrap.create(DbTypeEnum.CASSANDRA, properties,null,null);
     */
    NoSqlEntityManagerFactory factory = Bootstrap.create(DbTypeEnum.IN_MEMORY, properties,null,null);
    mgr = factory.createEntityManager();


   String file_to_use = userData;
   SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
   System.out.println("Starting inserts with file "+file_to_use+" at "+sdf.format(Calendar.getInstance().getTime()));

   BufferedReader CSVFile = null;
   try {
        CSVFile = new BufferedReader(new FileReader(file_to_use));
    } catch (FileNotFoundException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
     String dataRow = null;
    try {
        dataRow = CSVFile.readLine();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } // Read the first line of data.
      int i = 0; 
      while (dataRow != null){
          String[] dataArray = dataRow.split(",");
          User user = new User();
          user.setName(dataArray[0]);
          user.setAge(Integer.parseInt(dataArray[1]));
          user.setLastName(dataArray[2]);
          System.out.println("Inserting Values "+dataArray[0]+" "+dataArray[1]+" "+dataArray[2]);


          mgr.flush();
          try {
            dataRow = CSVFile.readLine();
        } catch (IOException e) {
            e.printStackTrace();
        }
      }

     java.util.List<User> result;
     System.out.println("#### By LastName ####");
     result = User.findByLastName(mgr, "Freida");
     System.out.println("Result Size: "+ result.size());

     System.out.println("#### By Time ####");
     result = User.findByName(mgr, "John");
     System.out.println("Result Size: "+ result.size());
}
}

ユーザーデータの内容:

John,17,Freida
Jim,18,Freida
Jam,19,Freida
Johny,20,Freida
Jen,21,Freida