最近、Cassandra データベースを使い始めました。ローカル マシンで単一ノード クラスタをセットアップできました。
そして今、私は を使用して Cassandra Database にいくつかのサンプル データを書き始めることを考えていましたPelops client
。
以下は、これまでに作成したキースペースと列ファミリーです-
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';
以下は私がこれまでに持っているコードです。以前と同じように、いくつかの例外が発生しましたが、それを修正できました。今、別の例外が発生しています
public class MyPelops {
private static final Logger log = Logger.getLogger(MyPelops.class);
public static void main(String[] args) throws Exception {
// 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 = new Cluster(NODES, 9160);
Pelops.addPool(THRIFT_CONNECTION_POOL, cluster, KEYSPACE);
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()));
mutator.writeColumn(
COLUMN_FAMILY,
"Row1",
new Column().setName(" Work ".getBytes()).setValue(
" Engineer ".getBytes()));
log.info("- Execute -");
mutator.execute(ConsistencyLevel.ONE);
Selector selector = Pelops.createSelector(THRIFT_CONNECTION_POOL);
int columnCount = selector.getColumnCount(COLUMN_FAMILY, "Row1",
ConsistencyLevel.ONE);
log.info("- Column Count = " + columnCount);
List<Column> columnList = selector
.getColumnsFromRow(COLUMN_FAMILY, "Row1",
Selector.newColumnsPredicateAll(true, 10),
ConsistencyLevel.ONE);
log.info("- Size of Column List = " + columnList.size());
for (Column column : columnList) {
log.info("- Column: (" + new String(column.getName()) + ","
+ new String(column.getValue()) + ")");
}
log.info("- All Done. Exit -");
System.exit(0);
}
}
このプログラムを実行しているときはいつでも、この例外が発生します-
Exception in thread "main" org.scale7.cassandra.pelops.exceptions.InvalidRequestException: Column timestamp is required
そして、この例外は、この行を実行しようとするとすぐに発生します-
mutator.execute
ライン
上で述べたように、私は Cassandra Database と Pelops クライアントも初めてです。それを扱うのはこれが初めてです。段階的なプロセスでこの問題を解決できる人はいますか? ローカル ボックスで Cassandra 1.2.3 を実行しています。
Cassandra データベースにデータを挿入する方法などの段階的なガイダンスは、Cassandra の仕組みを理解するのに大いに役立ちます。
前もって感謝します。