phantom-dsl

3熱

1答えて

現在の実装をPhantom 1.28.16から2.16.4に移行しようとしていますが、セットアップに問題があります。私たちのフレームワークは、起動時にPhantomに適合しないようなCassandraセッションオブジェクトを提供しています。私はPhantomに、通常のCassandraConnectionオブジェクトを経由するのではなく、すでにインスタンス化されたセッションを受け入れるようにして

0熱

1答えて

cassandraファントムを使用するコンタクトポイントなしでクラスタを構築できない

私はcassandra 5.2でファントム2.12.1を使用しています。私は、ドッキングウィンドウを使用してカサンドラを実行していますし、私はこの厄介なエラー得続ける：任意のアイデアはどのようなことを引き起こす可能性がありますか？ Caused by: java.lang.IllegalArgumentException: Cannot build a cluster without cont

3熱

1答えて

含まれる条件を使用してPhantomのListColumn [String]からデータを取り出す方法

私は、name_list extends ListColumn[String]とid extends StringColumn with PartitionKeyの列を持つCassandraテーブルDepartmentを持っています。私は、要求された名がNAME_LISTに存在しているIDを取得したいです。オペレータselect(_.id).where(name in name_list)でを

2熱

2答えて

ファントムのSetColumn [文字列]からフィールドを選択する方法

私はカッサンドラのテーブルDepartmentにカラムname_list extends SetColumn[String] with PartitionKeyとid extends StringColumn with PartitionKeyがあります。私は、要求された名がNAME_LISTに存在しているIDを取得したいです。私は以下のコードを使用してみましたが、どんな結果 abstract

0熱

1答えて

Phantom-DSLのContactPointとContactPoint

なぜPhantom-DSLにContactPointとContactPointが2つの異なる方法でConnectorに対応していますか？ ContactPointを使用している間、私はホストを使用して省略することができますかホスト文字列としてを持っていますが、私はここでポートを宣言することができます。 val default: CassandraConnection = ContactPoint(

0熱

1答えて

ファントムカサンドラのカスタムユーザ定義タイプ

私はファントムでカスタムUDTを作成しようとしています。与えられた case class CreationTrack(source_ip: String, created_by: String, created_at: UUID) abstract class Registrations extends CassandraTable[Registrations, CreationTrack]

0熱

1答えて

ファントムDSL条件付き更新

次の条件付き更新でfalseを返しました。しかし、データベースをチェックインすると、私が更新しようとしていた列が実際に更新されています。 def deliver(d: Delivery, placedDate: java.time.LocalDate, locationKey: String, vendorId: String, orderId: String, code: String, cou

0熱

1答えて

取得WriteTimoutException

は、しかし、このクエリは失敗し続けて： INSERT INTO test_db.test_tbl(name, last, ts) VALUES('aaa', 'bbb', 1502109409) IF NOT EXISTS USING TTL 0; 私は次の例外取得しています： com.datastax.driverを.core.exceptions.WriteTimeoutException：整

0熱

1答えて

UnsupportedOperationExeceptionカサンドラテーブル

に書くとき、私は次のクラスがあります：私は理解していない何 case class AucLog(timestamp: UUID, modelname: String, good: Int, list: List[Double]) class AucDatabase(override val connector : CassandraConnection) extends Da