.jarをアップロードせずに、既存のStreamTableを外部に照会することは可能ですか?実行環境を取得してテーブル環境を取得しますか?動的な(連続的な)テーブル機能のため、Apache Flink Table 1.4のリリースを待っていました。私は何か他のことを期待していました。実行時にテーブルを変更し、そのパラメータを変更することが可能であると考えました。データストリームの上にデータベースビューを(連続または追加のみ)定義するのではなく、ライブクエリを実行するためです。私はいくつかのデータベースに私のテーブルをエクスポートし、SQLを使用してこのデータベースを動的にクエリすることができます知っているが、これは扱いにくいです。 Flinkの美しさは、すべてがリアルタイムですべてがストリームなので、外部プログラムからリアルタイムでFlinkテーブルを照会することが可能ですか?Apache Flink表1.4:テーブルの外部SQL実行は可能ですか?
1
A
答えて
3
いいえ、現時点ではサポートされていません。
ストリーミングクエリの結果テーブルをクエリ可能な状態として格納する作業が行われています。これにより、固定キー属性に対するポイント(キールックアップ)照会が可能になります。この機能はFlink 1.5で利用できるようになります。
ストリーミングSQL(またはテーブルAPI)クエリによって生成された動的テーブルでSQLクエリをサポートする具体的な計画はありません。テーブルをRDBMSに発行し、そこからデータを照会する必要があります。
関連する問題
- 1. Apache Flink:実行時の状態パラメータを外部から変更する
- 2. kafka-apache flink実行log4jエラー
- 3. ApacheのFLINK:私は私のFLINKアプリケーションを実行するとTupleSerializer
- 4. 外部実行可能コンテンツ(外部のJavaScript)を禁止できますか?
- 5. Flink 1.2.0でElasticsearch 5.xを実行することは可能ですか?
- 6. ApacheのFLINK:私のアプリケーションでは、外部/着信拒否
- 7. Nodejs、外部実行可能ファイルをチェックできますか?
- 8. flinkテーブルSQL Api
- 9. Apache Flink実行時コンテキストのドキュメントはありますか?
- 10. Visual C++ 2003で外部実行可能ファイルに接続する
- 11. Flink 1.4カラム 'rowtime'がテーブルに見つかりません
- 12. Azure SQLの外部テーブルから "INSERT INTO"を実行できません
- 13. ApacheのFLINK:ウィンドウ表示ReduceFunctionは以下
- 14. ApacheのFLINKは、[]カフカ
- 15. Apache用の動的ストリームSQL Flink CEP
- 16. 自己実行機能はDOMで実行可能ですか?
- 17. 外部ライブラリを持つ実行可能なjar
- 18. Apache Flinkでのグローバルソート
- 19. flink web uiのタスクマネージャUIの外部JVMとは何ですか?
- 20. のApache FLINK 1.3テーブルAPI rowtime奇妙な行動
- 21. 内部LOBワークフローの実行可能メッセージ
- 22. Hadoop MapReduceを実行すると、外部実行可能ファイルをHDFSの外で呼び出すことが可能です
- 23. Firebase Authを外部SQLデータベースと統合することは可能ですか?
- 24. Pythonスクリプトから起動すると外部実行可能ファイルがクラッシュする
- 25. Apache ApexとApache Flink
- 26. 'app'レベルのdjango 1.4でのインポートは可能ですか?
- 27. 子テーブルの行を持たないSQL SELECTの外部キー行
- 28. C#アセンブリファイルは実行可能ですか?
- 29. テーブルにSQLクエリを保存し、オンザフライで実行する - 可能?いい練習?
- 30. ライダーの内部でUnity3Dテストを実行することは可能ですか?
これはデータの重複を招きます。自動データキューブ作成と変換ステップの場合は問題ありません。 Flinkでこれを実装するのがなぜ難しいのか知っていますか? jobmanagerはテーブル環境を知っている必要があり、テーブルはストリームの上に定義されたビューにすぎません(これはすでにsqlのような構文で作成されています)。そのSQLエンジンを使用し、jobmanagerでいくつかの残りのエンドポイントを開いて、いくつかのSQLクエリを既に作成された名前付きビューに送信できないのはなぜですか? – bl4ckbird
データテーブルは、クラスタ全体に分散され、ストリーミングジョブによってのみアクセス可能なFlinkの状態バックエンドに存在します(クエリ可能な状態のキー検索クエリを除きます)特徴)。このような機能を実装するには、その場での変更が必要であり、大きな工学的努力が必要です。現在、コミュニティはSQLカバレッジの拡張に時間を費やしています。 –
この文をありがとうございました:)多分私はこの種のクエリにtimeseries dbを使用します – bl4ckbird