我的cassandra表有一个日期类型列,如下所示:
create table people
(
id int primary key,
name text,
email text,
dob date
);
我使用的是SpringBoot 1.5.2 +。
@Table("people")
public class Person {
@PrimaryKey
Integer id;
private String name;
private String email;
private java.util.Date
我试图通过spring在cassandra中自动保存日期,并将使用spring (日期)获得的日期类型更改为Cassandra格式(日期yyyy dd)。
控制器
@PostMapping("/add")
public ResponseEntity<Cliente> crearCliente(@RequestBody Cliente cliente) {
Date fecha = new Date();
System.out.println(fecha);
long lnMilisegundos = fecha.getTime();
我正在处理非常长的时间序列--一个序列中有数亿个数据点--我正在考虑将Cassandra作为一个数据存储。在中,一位Cassandra提交者(theüber helpful )表示,Cassandra行可能非常大,列切片操作比行切片更快,因此我的问题是:行大小是按可用内存计算的吗?( by available memory?
我加载到Cassandra中的数据包含日期(时间戳类型)。我需要使用这些日期进行计算,例如,计算给定日期和now()之间的差值,或者两个date (时间戳类型)列之间的差值。 我试过了: SELECT x, date_1 - date_2 as age FROM y WHERE a = 'z'; 我尝试了圆括号、“AS”子句和将时间戳转换为date类型,但收到了错误。 我还尝试创建了一个UDF(用户定义函数): CREATE OR REPLACE FUNCTION x.age_calc (tounixtimestamp(date_1) int, tounixtimestam
我需要创建一个Cassandra表,特定的查询将对其执行操作。
我需要能够基于日期范围、类型和一个或多个状态对此表进行搜索。更具体地说,查询将如下所示:
select * from table where date IN range (from,to),type = 'some type‘,status in (status1,status2,...,statusN)
由于Cassandra不允许对分区键进行比较操作,因此我决定将date (Java中的Instant类型)分解为MONTH_YEAR。例如,日期2015/21/12:19:02:01将转换为122015 (12是该日期的
我试图从Cassandra的日期范围获取数据,表如下所示:
CREATE TABLE test6 (
time timeuuid,
id text,
checked boolean,
email text,
name text,
PRIMARY KEY ((time), id)
)
但是,当我选择一个数据范围时,我什么也得不到:
SELECT * FROM teste WHERE time IN ( minTimeuuid('2013-01-01 00:05+0000'), now() );
(0 rows)
如何从Cassandra查询中获得日期范围
我对卡桑德拉还有另一个问题..我在Mysql中导出了一个.csv格式的表,并将其导入到Cassandra.the中,Mysql表包含日期和时间类型的文件日期和时间。我在cassandra中将这些字段定义为varchar。因此,当我导入.csv文件并执行下面的查询时,它显示了一个错误: my query:
ResultSet rs = stmnt.ExecuteQuery("Select * from station info where IDstation = 1011 and IDinfo = 18412:);
while (rs.next) {
System.out.prin
我已经在php中使用new Cassandra\Timestamp()生成了时间戳。现在,我想使用php将生成的时间增加2小时,然后将其存储在数据库(Cassandra)中。 从本质上讲,我想做这样的事情: $dt= new Cassandra\Timestamp();
$new_dt= $dt+3*3600; //here 3 is in hours
$query=$session->prepare('INSERT INTO tracker_table(id,deadline)VALUES(?,?)');
$session->execute($q