表中未显示java数据
我试图对我的Cassandra进行压力测试，由于某种原因，我的Cassandra压力工具无法在windows上工作，因此作为一种解决方法，我向C*发出了100000次循环POST请求，后端是JAVA
我的cassandra表架构是：-
CREATE TABLE Stress2.demomodel(acctID TEXT, transactionDate Date , card TEXT, amountCreditedFrom TEXT ,transactionAmount double ,balance DOUBLE, currentTime timestamp , PRIMARY KEY((acctID, transactionDate), currentTime )) WITH CLUSTERING ORDER BY (currentTime DESC);
这是我的循环代码
@Override
public DemoModel save(DemoModel demoModel) {
int i = 0;
try {
for (i = 0; i < 100000; i++) {
Thread.sleep(2L);
demoRepository.save(demoModel);
}
}
catch(Exception e) {
throw new RuntimeException("worked till " + i);
}
return null;
}
在运行循环之前，这是压力工具提供的统计数据
Keyspace : stress2
Read Count: 0
Read Latency: NaN ms
Write Count: 2
Write Latency: 0.1565 ms
Pending Flushes: 0
Table: demomodel
SSTable count: 0
Space used (live): 0 bytes
Space used (total): 0 bytes
Space used by snapshots (total): 0 bytes
Off heap memory used (total): 342 bytes
SSTable Compression Ratio: -1.0
Number of partitions (estimate): 1
Memtable cell count: 2
Memtable data size: 266 bytes
Memtable off heap memory used: 342 bytes
Memtable switch count: 0
Local read count: 0
Local read latency: NaN ms
Local write count: 2
Local write latency: 0.152 ms
Pending flushes: 0
Percent repaired: NaN
Bytes repaired: 0.000KiB
Bytes unrepaired: 0.000KiB
Bytes pending repair: 0.000KiB
Bloom filter false positives: 0
Bloom filter false ratio: 0.00000
Bloom filter space used: 0 bytes
Bloom filter off heap memory used: 0 bytes
Index summary off heap memory used: 0 bytes
Compression metadata off heap memory used: 0 bytes
Compacted partition minimum bytes: 0
Compacted partition maximum bytes: 0
Compacted partition mean bytes: 0
Average live cells per slice (last five minutes): 2.0
Maximum live cells per slice (last five minutes): 2
Average tombstones per slice (last five minutes): 1.0
Maximum tombstones per slice (last five minutes): 1
Dropped Mutations: 0 bytes
Failed Replication Count: null
循环完成后，这就是统计数据，正如我们可以看到的，memtable的大小增加到13MB
Keyspace : stress2
Read Count: 0
Read Latency: NaN ms
Write Count: 100002
Write Latency: 0.045491610167796646 ms
Pending Flushes: 0
Table: demomodel
SSTable count: 0
Space used (live): 0 bytes
Space used (total): 0 bytes
Space used by snapshots (total): 0 bytes
Off heap memory used (total): 13.26 MiB
SSTable Compression Ratio: -1.0
Number of partitions (estimate): 1
Memtable cell count: 100002
Memtable data size: 399 bytes
Memtable off heap memory used: 13.26 MiB
Memtable switch count: 0
Local read count: 0
Local read latency: NaN ms
Local write count: 100002
Local write latency: 0.045 ms
Pending flushes: 0
Percent repaired: NaN
Bytes repaired: 0.000KiB
Bytes unrepaired: 0.000KiB
Bytes pending repair: 0.000KiB
Bloom filter false positives: 0
Bloom filter false ratio: 0.00000
Bloom filter space used: 0 bytes
Bloom filter off heap memory used: 0 bytes
Index summary off heap memory used: 0 bytes
Compression metadata off heap memory used: 0 bytes
Compacted partition minimum bytes: 0
Compacted partition maximum bytes: 0
Compacted partition mean bytes: 0
Average live cells per slice (last five minutes): 2.0
Maximum live cells per slice (last five minutes): 2
Average tombstones per slice (last five minutes): 1.0
Maximum tombstones per slice (last five minutes): 1
Dropped Mutations: 0 bytes
Failed Replication Count: null
现在，当我尝试刷新时，希望压缩分区中有一些数据，奇怪的是，数据非常少，下面是统计数据
Keyspace : stress2
Read Count: 0
Read Latency: NaN ms
Write Count: 100002
Write Latency: 0.045491610167796646 ms
Pending Flushes: 0
Table: demomodel
SSTable count: 1
Space used (live): 5.29 KiB
Space used (total): 5.29 KiB
Space used by snapshots (total): 0 bytes
Off heap memory used (total): 8 bytes
SSTable Compression Ratio: 0.5753424657534246
Number of partitions (estimate): 1
Memtable cell count: 0
Memtable data size: 0 bytes
Memtable off heap memory used: 0 bytes
Memtable switch count: 1
Local read count: 0
Local read latency: NaN ms
Local write count: 100002
Local write latency: 0.045 ms
Pending flushes: 0
Percent repaired: 0.0
Bytes repaired: 0.000KiB
Bytes unrepaired: 0.214KiB
Bytes pending repair: 0.000KiB
Bloom filter false positives: 0
Bloom filter false ratio: 0.00000
Bloom filter space used: 16 bytes
Bloom filter off heap memory used: 8 bytes
Index summary off heap memory used: 0 bytes
Compression metadata off heap memory used: 0 bytes
Compacted partition minimum bytes: 216
Compacted partition maximum bytes: 258
Compacted partition mean bytes: 258
Average live cells per slice (last five minutes): 2.0
Maximum live cells per slice (last five minutes): 2
Average tombstones per slice (last five minutes): 1.0
Maximum tombstones per slice (last five minutes): 1
Dropped Mutations: 0 bytes
Failed Replication Count: null
现在，至少当我查询表时，只有3行，但我们可以看到LocalWriteCount>；100000
这是我的模式数据模型
package com.example.connectCass.Model;
import lombok.Data;
import org.springframework.data.cassandra.core.cql.PrimaryKeyType;
import org.springframework.data.cassandra.core.mapping.Column;
import org.springframework.data.cassandra.core.mapping.PrimaryKeyColumn;
import org.springframework.data.cassandra.core.mapping.Table;
import com.datastax.driver.core.LocalDate;
import java.util.Date;
@Data
@Table
public class DemoModel {
@PrimaryKeyColumn(name = "acctID", type = PrimaryKeyType.PARTITIONED)
private String acctID;
@PrimaryKeyColumn(name = "transactionDate", type = PrimaryKeyType.PARTITIONED)
private LocalDate transactionDate;
@PrimaryKeyColumn(name = "currentTime", type = PrimaryKeyType.CLUSTERED)
private Date currentTime;
@Column
private String card;
@Column
private String amountCreditedFrom;
@Column
private double transactionAmount;
@Column
private double balance;
public void setTransactionDate(){
this.transactionDate =LocalDate.fromMillisSinceEpoch(new Date().getTime());
}
public void setCurrentTime(){
this.currentTime = new Date();
}
}
有人能告诉我哪里出了问题吗？ 谢谢
共 (0) 个答案