0
ソースのCassandraコネクタがhttps://flink.apache.org/ecosystem.htmlに表示されません。 Cassandraに保存されているデータをどのように使用すればよいのでしょうか。CEP用にapache-flinkを使用していて、Cassandraに状態用に使用したいデータがある場合、どうすればいいですか？
おかげ
A
答えて
1
1の方法は、Cassandra to Kafkaからデータを送信し、その後Kafka as the data sourceを使用することです。
関連する問題
- 1. システムアイドル状態をチェックし、5分後にシステムをログアウト状態にする（使用していない場合）
- 2. enum値を状態図の状態として使用するにはどうすればよいですか？
- 3. tryステートメントを使用して競合状態を回避するにはどうすればよいですか？
- 4. lxmlを使用している場合、httpsについてどうすればいいですか？
- 5. spark-cassandra-connectorを使用してsparkとcassandraを接続するにはどうすればいいですか？
- 6. ローカル通知を使用してアプリをスリープ状態にするにはどうすればよいですか？
- 7. JavaScriptを使用してハイパーリンクの状態を確認するにはどうすればよいですか？
- 8. Reactive Extensionsを使用して状態をポーリングするにはどうすればよいですか？
- 9. Angular UI-Routerを使用して状態を取得するにはどうすればよいですか？
- 10. jsonファイルを使用してjqueryデータテーブルの状態をロードするにはどうすればよいですか？
- 11. LinQのどこで使用するかEntityフレームワークを使用しているデータが大量に含まれている場合があります
- 12. cassandraがflywayでサポートされていない場合でも、cassandraにflywayを使用する方法
- 13. PHPを使用している場合にCSSが適用されない
- 14. Webpackを使用している場合、どのフォルダを静的に使用していますか？
- 15. codeigniterを使用して行データの合計を表示するにはどうすればいいですか？
- 16. jQueryを使用してdivの現在の状態を返すにはどうすればよいですか？
- 17. Yamlファイルでregexを使用してLogstashを使用するにはどうすればいいですか？
- 18. ログインページ（php）に128bit SSLを使用したい場合はどうすればいいですか
- 19. CycledLeScanCallbackにAndroid-Beacon-libraryを使用したい場合はどうすればいいですか
- 20. PHPスクリプトを使用してデータをエクスポートしてインポートするにはどうすればいいですか？
- 21. Cassandra 3でCQLを使用して、テーブルがコンパクトストレージを使用するかどうかを判断するにはどうすればよいですか？
- 22. 汎用インターフェースを汎用制約として使用するにはどうすればいいですか？
- 23. Jqueryを使用してnon rest wcfサービスを使用するにはどうすればいいですか？
- 24. Python 2.6のpthファイルを使用してカスタムサイトパッケージを使用するにはどうすればいいですか？
- 25. drupal8コンポーザーを使用してウェブサイトをインストールして使用するにはどうすればよいですか？
- 26. java APIを使用してcassandraデータベースにJSONを挿入するにはどうすればよいですか？
- 27. は私がoccuringから、このような競合状態を防ぐにはどうすればよい（Laravelを）データベーストランザクションを使用した競合状態を
- 28. セッション状態は、enableSessionStateがtrueに設定されている場合にのみ使用できます。Server.Transferを使用する場合は
- 29. Hectorを使用してCassandraに再接続するにはどうすればよいですか？
- 30. テーマを使用してアクションバーが表示されない状態で新しいアクティビティを開始するにはどうすればよいですか？
「[apache flink Java APIを使用してcassandraにデータを読み書きする]」（https://stackoverflow.com/questions/42617575/read-write-data-into-cassandra-using-apache-flink-java- API） –