Flink コネクタの連続読み取り

Flink は、非ストリームレイヤーから継続的にデータを読み取ることができます。 つまり、 Flink 実行環境の実行時に、通常のストリーム レイヤー処理が進行中であり、非ストリームレイヤーのデータに変更がある場合、データが読み取られて処理に挿入されます。 この機能を使用すると、 Flink 実行環境の起動時だけでなく、実行時にもこのようなレイヤーを一度読み取ることができます。

この動作は、次のようなレイヤータイプによって若干異なります。

• バージョン付レイヤー：

  バージョン付レイヤーの場合、この機能はデフォルトで有効になっています。 レイヤー通知を使用します。 そのため、ポーリングする必要はありませんが、新しいバージョンが公開された場合は通知が送られます。 この関数を無効にするに olp.connector-refresh-interval-1 は、値を持つプロパティを環境またはアプリケーションの構成に追加するだけです。

  注 : バージョン付レイヤーの場合、この機能は notificationsEnabled = true カタログ設定にが含まれているカタログにのみ使用できます。

• 揮発性、インデックス、およびインタラクティブなマップレイヤー :

  これらのレイヤーでは olp.connector-refresh-interval 、環境またはアプリケーション設定にプロパティを追加することで、更新 ( ポーリング ) 間隔をミリ秒単位で定義できます。 デフォルトでは、この間隔 60000L は 60 秒を意味します。