0

最近、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 の仕組みを理解するのに大いに役立ちます。

前もって感謝します。

4

1 に答える 1

1

cassandra の各列は、Key-Value-Timestamp トリプレットです。あなたの列にタイムスタンプを設定しませんでした

Column c = new Column();
c.setTimestamp(System.currentTimeMillis());

クライアントの方法を使用して列を作成し、ジョブを簡単にすることができます

   mutator.writeColumn(
            COLUMN_FAMILY,
            "Row1",
            mutator.newColumn(" Name ", " Test One "));

このようにして、タイムスタンプの設定 (クライアントが自動的に行います) と String での getBytes() の使用の両方を回避できます。

よろしく、 カルロ

于 2013-04-09T14:55:53.430 に答える