2017-10-25 9 views
1

.jarをアップロードせずに、既存のStreamTableを外部に照会することは可能ですか?実行環境を取得してテーブル環境を取得しますか?動的な(連続的な)テーブル機能のため、Apache Flink Table 1.4のリリースを待っていました。私は何か他のことを期待していました。実行時にテーブルを変更し、そのパラメータを変更することが可能であると考えました。データストリームの上にデータベースビューを(連続または追加のみ)定義するのではなく、ライブクエリを実行するためです。私はいくつかのデータベースに私のテーブルをエクスポートし、SQLを使用してこのデータベースを動的にクエリすることができます知っているが、これは扱いにくいです。 Flinkの美しさは、すべてがリアルタイムですべてがストリームなので、外部プログラムからリアルタイムでFlinkテーブルを照会することが可能ですか?Apache Flink表1.4:テーブルの外部SQL実行は可能ですか?

答えて

3

いいえ、現時点ではサポートされていません。

ストリーミングクエリの結果テーブルをクエリ可能な状態として格納する作業が行われています。これにより、固定キー属性に対するポイント(キールックアップ)照会が可能になります。この機能はFlink 1.5で利用できるようになります。

ストリーミングSQL(またはテーブルAPI)クエリによって生成された動的テーブルでSQLクエリをサポートする具体的な計画はありません。テーブルをRDBMSに発行し、そこからデータを照会する必要があります。

+0

これはデータの重複を招きます。自動データキューブ作成と変換ステップの場合は問題ありません。 Flinkでこれを実装するのがなぜ難しいのか知っていますか? jobmanagerはテーブル環境を知っている必要があり、テーブルはストリームの上に定義されたビューにすぎません(これはすでにsqlのような構文で作成されています)。そのSQLエンジンを使用し、jobmanagerでいくつかの残りのエンドポイントを開いて、いくつかのSQLクエリを既に作成された名前付きビューに送信できないのはなぜですか? – bl4ckbird

+0

データテーブルは、クラスタ全体に分散され、ストリーミングジョブによってのみアクセス可能なFlinkの状態バックエンドに存在します(クエリ可能な状態のキー検索クエリを除きます)特徴)。このような機能を実装するには、その場での変更が必要であり、大きな工学的努力が必要です。現在、コミュニティはSQLカバレッジの拡張に時間を費やしています。 –

+0

この文をありがとうございました:)多分私はこの種のクエリにtimeseries dbを使用します – bl4ckbird

関連する問題