java - 如何在 cassandra 中添加列以使用 Java API 进行批量加载？

Question

我正在尝试添加列，但它不起作用我有（总共 10 列）三个复合键和 7 列（复合键除外）
我想在我的 api 中添加这些列以构建 sstable 以使用 SstableLaoder 加载到 cassandra

我得到这个例外：

“复合柱已经完全建成”

生成器 builder = compositeColumn.builder();

 while ((line = reader.readLine()) != null)
        {
          if (entry.parse(line, lineNumber))

{

       usersWriter.newRow(bytes(entry.sn));
        builder.add(bytes(entry.ts));
        builder.add(bytes(entry.dn));
 builder.add(bytes(entry.re));
//builder.add(bytes(entry.password));
        //builder.add(bytes(entry.email));

        usersWriter.addColumn(builder.add(bytes("ds")).build(),bytes(entry.ds), timestamp);
        //usersWriter.addColumn(builder.add(bytes("re")).build(),bytes(entry.re), timestamp);
//      usersWriter.addColumn(builder.add(bytes("age")).build(),bytes(entry.age), timestamp);
//      usersWriter.addColumn(builder.add(bytes("password")).build(),bytes(entry.password), timestamp);
//      usersWriter.addColumn(builder.add(bytes("email")).build(),bytes(entry.email), timestamp);
 //usersWriter.addColumn(builder.add(bytes("msgid")).build(),bytes(entry.key), timestamp);

        builder = compositeColumn.builder();
 System.out.println(lineNumber);

}