ストリームの処理中です

HERE platform は 、ストリーミングパイプラインを実行するための Apache Flink フレームワークをサポートしています。 Flink Connector と Flink Support の 2 つの異なるモジュールを提供しています。

Flink Connector は現在、読み取りおよび書き込みのためのストリーム、インデックス、および揮発性レイヤーをサポートし、読み取り専用のバージョン管理されたレイヤーをサポートしています。

HERE では、可能な限り Flink Connector を使用することを強くお勧めします。これにより、 Apache Flink フレームワークのすべての機能を利用できるようになります。

Flink コネクタと Flink サポートモジュールを組み合わせることができます。

Flink Connector は、読み取り Table用のソースを作成し、 Tableストリームレイヤーに書き込むためのシンクを可能にする標準の Flink インターフェイスを実装します。

その結果、 Flink でサポートされているリレーショナル API ( Table API および)の両方を使用 SQLできます。 さらに、 Table をに変換し DataStream 、 Flink を使用 DataStream APIできます。

つまり、ビジネスロジックに HERE 固有の関数呼び出しを含める必要はありません。

Flink コネクタの詳細については 、「 Flink コネクタ」を参照してください。

Flink サポートは、 HERE platform カタログおよびレイヤーのデータを Apache Flink フレームワークで使用する、 HERE 独自の実装です。 処理ジョブのワーカーへの配布は Flink によって行われますが、データモデルは HERE 独自の形式です。 SQL に似たインターフェイスがないため 、Table APIを使用してデータを選択およびフィルタリングすることはでき ません

最後に、FlinkDataClientは、すべての非同期通信が Flink SourceおよびSinkインターフェイスで使用できるように同期化されていることを確認するための定期的なDataClientラッパーです。 表形式のアクセスには、追加の機能はありません。

Flink サポートの詳細については 、 Flink サポートを参照してください。

制限事項

Protobuf メッセージを処理する場合 SdiiMessage.Message、シリアライザーを環境に登録する必要があります。

Scala
Java
env.getConfig.registerTypeWithKryoSerializer(
  classOf[SdiiMessage.Message],
  classOf[ProtobufKryoSerializer[SdiiMessage.Message]])
env.getConfig()
    .registerTypeWithKryoSerializer(SdiiMessage.Message.class, ProtobufKryoSerializer.class);

」に一致する結果は 件です

    」に一致する結果はありません