Cassandra Hadoop 連携

このドキュメントの内容は、以下の通りです。

• ダウンロード
• ant のインストール
• hadoop_work_count のビルド

ダウンロード

• http://cassandra.apache.org/download/
• http://www.apache.org/dyn/closer.cgi?path=/cassandra/1.1.2/apache-cassandra-1.1.2-src.tar.gz

wget http://ftp.kddilabs.jp/infosystems/apache/cassandra/1.1.2/apache-cassandra-1.1.2-src.tar.gz

ant のインストール

hadoop_work_count のビルド

tar zxfp apache-cassandra-1.1.2-src.tar.gz
cd apache-cassandra-1.1.2-src/
ant
cd examples/
cd hadoop_word_count/
ant

build:
    [javac] /home/kaworu/cassandra/src/apache-cassandra-1.1.2-src/examples/hadoop_word_count/build.xml:64: warning: 'includeantruntime' was not set, defaulting to build.sysclasspath=last; set to false for repeatable builds
    [javac] Compiling 3 source files to /home/kaworu/cassandra/src/apache-cassandra-1.1.2-src/examples/hadoop_word_count/build/classes

jar:
    [mkdir] Created dir: /home/kaworu/cassandra/src/apache-cassandra-1.1.2-src/examples/hadoop_word_count/build/classes/META-INF
      [jar] Building jar: /home/kaworu/cassandra/src/apache-cassandra-1.1.2-src/examples/hadoop_word_count/build/word_count.jar

BUILD SUCCESSFUL
Total time: 30 seconds

% sh  bin/word_count_setup
12/07/21 01:28:01 INFO WordCountSetup: added text1
12/07/21 01:28:01 INFO WordCountSetup: added text2
12/07/21 01:28:02 INFO WordCountSetup: added text3
12/07/21 01:28:03 INFO WordCountSetup: added text4
12/07/21 01:28:03 INFO WordCountSetup: added key-if-verse1

% sh  bin/word_count

% sh  bin/word_count_counters

% cassandra-cli -h localhost -k wordcount
[default@wordcount] list output_words;
Using default limit of 100
Using default column limit of 100
-------------------
RowKey: 73756d
=> (column=0, value=250, timestamp=1342802861125)
=> (column=1, value=250, timestamp=1342802861130)
=> (column=2, value=250, timestamp=1342802861134)
=> (column=3, value=250, timestamp=1342802861137)
=> (column=word1, value=2002, timestamp=1342802861166)
=> (column=word2, value=1, timestamp=1342802861167)

1 Row Returned.
Elapsed time: 3 msec(s).