0

我正在使用 Cassandra 数据库。我创建了一个下面的列族

create column family USER
with comparator = 'UTF8Type'
and default_validation_class = 'UTF8Type'
and column_metadata = [
                {column_name : account, validation_class : 'UTF8Type'}
                {column_name : lmd, validation_class : 'DateType'}

];

现在我正在尝试使用插入 Cassandra 数据库Pelops client

mutator.writeColumns(column_family, String.valueOf(userId),
                        mutator.newColumnList(
                        mutator.newColumn("account", "hello"), 
                        mutator.newColumn("lmd", String.valueOf(new Date().getTime()))                  
                    ));

就我而言,我DateType在列族中创建了 lmd,所以我不确定如何datetype通过代码添加它。目前我将它添加为字符串,但我需要确保它与DateType.

谁能帮我这个?

4

1 回答 1

0

好吧,您已经使用 cli 创建了一个列族。现在尝试使用这些

SET USER['somekey']['account']='AC-46113';
SET USER['somekey']['lmd']=1365490146534;
LIST USER;

现在你已经使用 pelops 做了同样的事情

mutator.writeColumns(column_family, String.valueOf(userId),
                    mutator.newColumnList(
                    mutator.newColumn("account", "hello"), 
                    mutator.newColumn("lmd", Bytes.fromLong(System.currentTimeMillis()))                  
                ));
于 2013-04-09T06:50:02.417 回答