17

最近、Cassandra データベースを使い始めました。single node clusterローカルボックスにインストールしました。そして、私はで働いていCassandra 1.2.3ます。

インターネットで記事を読んでいて、この行を見つけました-

Cassandra の書き込みは、最初にコミット ログに書き込まれ (耐久性のため)、次に memtable と呼ばれるメモリ内のテーブル構造に書き込まれます。書き込みはコミット ログとメモリに書き込まれると成功するため、書き込み時のディスク I/O は最小限に抑えられます。書き込みはメモリ内でバッチ処理され、定期的にディスクの SSTable (ソートされた文字列テーブル) と呼ばれる永続的なテーブル構造に書き込まれます。

上記の行を理解するために、Pelops client. そして、Cassandra データベースにデータを挿入することができました。

そして今、私は自分のデータがどのように書き込まれたのか、そしてそれがcommit logどこにあるのかを確認しようとしてcommit log fileいます? また、どのようSSTablesに生成され、どこでそれを見つけることができるか、ローカル ボックスとそれに含まれるものについても説明します。

この 2 つのファイルを確認して、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 を開くと、まず大量のデータが含まれているため、メモ帳 ++ で正しく開くことができず、開いた場合、何らかのエンコーディングなどのために正しく表示されません。私のデータフォルダでは、何も見つかりませんか?

つまり、このフォルダは私にとって空です-

S:\Apache Cassandra\apache-cassandra-1.2.3\storage\data\my_keyspace\users

ここに欠けているものはありますか？commitLog と SSTables ファイルの読み方と、これら 2 つのファイルの場所を教えてもらえますか? また、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';
4

1 に答える 1