Cassandra 查询列映射

Question

我有一个Cassandra表trans_by_date，其中包含列origin，tran_date（和其他一些列）。我尝试运行以下代码得到错误：

java.util.NoSuchElementException: Columns not found in table trans.trans_by_date : TRAN_DATE.  The column does exist. 

任何语法问题？

JavaRDD<TransByDate> transDateRDD = javaFunctions(sc)
.cassandraTable("trans", "trans_by_date", CassandraJavaUtil.mapRowTo(TransByDate.class))
.select(CassandraJavaUtil.column("origin"), CassandraJavaUtil.column("TRAN_DATE").as("transdate"));

 public static class TransByDate implements Serializable {
        private String origin;
        private Date transdate;
    public String getOrigin() { return origin; }
        public void setOrigin(String id) { this.origin = id; }
        public Date getTransdate() { return transdate; }
        public void setTransdate(Date trans_date) { this.transdate = trans_date; }
}

谢谢

Answer 1

如果你将CassandraJavaUtil.column（"TRAN_DATE"）更改为CassandraJavaUtil.column（"tran_date"），即只使用小写的列名，你的代码应该可以工作。

似乎CassandraJavaUtil在创建选择查询时将列名放在双引号中。

有关 cassandra 中的大写和小写处理，请参阅以下链接：https://docs.datastax.com/en/cql/3.3/cql/cql_reference/ucase-lcase_r.html