クラスターの起動

docker for macのVMに割り当てるメモリを4GBまで上げたら起動した。

version: "3"
services:
  cassandra1:
    image: cassandra
    environment:
      CASSANDRA_SEEDS: cassandra1
  cassandra2:
    image: cassandra
    environment:
      CASSANDRA_SEEDS: cassandra1
    depends_on:
      - cassandra1

コンテナにログインしてnodetool statusを実行すると、複数台のノードでクラスターが構成されていることがわかる。

% nodetool status

Datacenter: datacenter1
=======================
Status=Up/Down
|/ State=Normal/Leaving/Joining/Moving
--  Address     Load       Tokens       Owns (effective)  Host ID                               Rack
UN  172.18.0.2  146.6 KiB  256          100.0%            410c863f-f3e8-41e6-b297-f0f1e3bd7d33  rack1
UN  172.18.0.3  70.72 KiB  256          100.0%            a8585f68-ab42-4c87-a416-49fd48daadf7  rack1

パーティションの確認

nodetool ringを実行すると、各ノードが担当するトークンの範囲がわかる。

% nodetool ring

Datacenter: datacenter1
==========
Address     Rack        Status State   Load            Owns                Token
                                                                           9205355899184488755
172.18.0.3  rack1       Up     Normal  227.44 KiB      100.00%             -9182155964809320561
172.18.0.3  rack1       Up     Normal  227.44 KiB      100.00%             -9173740678595215345
172.18.0.2  rack1       Up     Normal  215.57 KiB      100.00%             -9155666247780803709
# (snip)
172.18.0.3  rack1       Up     Normal  227.44 KiB      100.00%             9151380247043298877
172.18.0.2  rack1       Up     Normal  215.57 KiB      100.00%             9160375385280096791
172.18.0.2  rack1       Up     Normal  215.57 KiB      100.00%             9205355899184488755

172.18.0.2と172.18.0.3のノードそれぞれにTokenが割り当てられている。Tokenの値は担当範囲の最後の値を表している。トークンはリング状に配置されるため、上の例で言うと最大値9205355899184488755の次の値は最小値-9182155964809320561ということになる。

次に実際にデータがどのパーティションに保存されているか確認する。まずは、適当なテーブルを追加してデータを入れる。

cqlsh:hello> create table users (id bigint primary key, name text);
cqlsh:hello> insert into users (id, name) values (1, 'alice');
cqlsh:hello> insert into users (id, name) values (2, 'bob');
cqlsh:hello> select * from users;

 id | name
----+-------
  2 |   bob
  1 | alice

(2 rows)

TOKEN関数を使うと、渡した値からトークンとなる値を計算できる。パーティションキーを渡してトークンを計算してみる。

cqlsh:hello> select id, token(id) from users;

 id | system.token(id)
----+----------------------
  2 | -8218881827949364593
  1 |  6292367497774912474

(2 rows)

これらの値とnodetool ringで見たトークンの範囲と見比べることで、その行がどのノードに保存されているか確認できる。先程のnodetool ringの結果を再掲すると以下のようになっている。

172.18.0.3  rack1       Up     Normal  227.44 KiB      100.00%             -8312964340927482628
172.18.0.2  rack1       Up     Normal  215.57 KiB      100.00%             -8169459460287760239
# (snip)
172.18.0.2  rack1       Up     Normal  215.57 KiB      100.00%             6147470985463054203
172.18.0.2  rack1       Up     Normal  215.57 KiB      100.00%             6312725102659141435

よって、id:2の行は172.18.0.2のノードに、id:1の行は同じく172.18.0.2のノードに保存されていることがわかった。