我最近开始使用 Cassandra 数据库。我已经安装single node cluster在我的本地盒子中。我正在与Cassandra 1.2.3.
我正在阅读互联网上的文章，我发现了这一行 -
Cassandra 写入首先写入提交日志（为了持久性），然后写入内存中的表结构，称为 memtable。一旦写入提交日志和内存，写入即成功，因此写入时磁盘 I/O 非常少。写入在内存中批量写入，并定期写入磁盘到称为 SSTable（排序字符串表）的持久表结构。
因此，为了理解以上几行，我编写了一个简单的程序，该程序将使用Pelops client. 我能够在 Cassandra 数据库中插入数据。
现在我想看看我的数据是如何写入的commit log以及它在哪里commit log file？还有如何SSTables生成的，我可以在我的本地盒子中找到它的位置以及它包含的内容。
我想看看这两个文件，以便我能更多地了解 Cassandra 在幕后是如何工作的。
在我的 cassandra.yaml 文件中，我有这样的东西
# directories where Cassandra should store data on disk.
data_file_directories:
- S:\Apache Cassandra\apache-cassandra-1.2.3\storage\data
# commit log
commitlog_directory: S:\Apache Cassandra\apache-cassandra-1.2.3\storage\commitlog
# saved caches
saved_caches_directory: S:\Apache Cassandra\apache-cassandra-1.2.3\storage\savedcaches
但是当我打开commitLog时，首先它有很多数据，所以我的notepad++无法正确打开它，如果它被打开，由于某些编码或什么，我无法正确看到。在我的数据文件夹中，我什么也找不到？
这意味着这个文件夹对我来说是空的-
S:\Apache Cassandra\apache-cassandra-1.2.3\storage\data\my_keyspace\users
我在这里有什么遗漏吗？谁能解释我如何阅读 commitLog 和 SSTables 文件以及在哪里可以找到这两个文件？以及每当我写入 Cassandra 数据库时，幕后究竟发生了什么。
更新：-
我用来插入 Cassandra 数据库的代码-
public class MyPelops {
private static final Logger log = Logger.getLogger(MyPelops.class);
public static void main(String[] args) throws Exception {
// -------------------------------------------------------------
// -- Nodes, Pool, Keyspace, Column Family ---------------------
// -------------------------------------------------------------
// A comma separated List of Nodes
String NODES = "localhost";
// Thrift Connection Pool
String THRIFT_CONNECTION_POOL = "Test Cluster";
// Keyspace
String KEYSPACE = "my_keyspace";
// Column Family
String COLUMN_FAMILY = "users";
// -------------------------------------------------------------
// -- Cluster --------------------------------------------------
// -------------------------------------------------------------
Cluster cluster = new Cluster(NODES, 9160);
Pelops.addPool(THRIFT_CONNECTION_POOL, cluster, KEYSPACE);
// -------------------------------------------------------------
// -- Mutator --------------------------------------------------
// -------------------------------------------------------------
Mutator mutator = Pelops.createMutator(THRIFT_CONNECTION_POOL);
log.info("- Write Column -");
mutator.writeColumn(
COLUMN_FAMILY,
"Row1",
new Column().setName(" Name ".getBytes()).setValue(" Test One ".getBytes()).setTimestamp(new Date().getTime()));
mutator.writeColumn(
COLUMN_FAMILY,
"Row1",
new Column().setName(" Work ".getBytes()).setValue(" Engineer ".getBytes()).setTimestamp(new Date().getTime()));
log.info("- Execute -");
mutator.execute(ConsistencyLevel.ONE);
// -------------------------------------------------------------
// -- Selector -------------------------------------------------
// -------------------------------------------------------------
Selector selector = Pelops.createSelector(THRIFT_CONNECTION_POOL);
int columnCount = selector.getColumnCount(COLUMN_FAMILY, "Row1",
ConsistencyLevel.ONE);
System.out.println("- Column Count = " + columnCount);
List<Column> columnList = selector
.getColumnsFromRow(COLUMN_FAMILY, "Row1",
Selector.newColumnsPredicateAll(true, 10),
ConsistencyLevel.ONE);
System.out.println("- Size of Column List = " + columnList.size());
for (Column column : columnList) {
System.out.println("- Column: (" + new String(column.getName()) + ","
+ new String(column.getValue()) + ")");
}
System.out.println("- All Done. Exit -");
System.exit(0);
}
}
我创建的键空间和列族-
create keyspace my_keyspace with placement_strategy = 'org.apache.cassandra.locator.SimpleStrategy' and strategy_options = {replication_factor:1};
use my_keyspace;
create column family users with column_type = 'Standard' and comparator = 'UTF8Type';