flink-kafka

:helicopter::rocket: Flinkベースの商品リアルタイム推薦システム。Flinkが商品の人気度を統計し、Redisにキャッシュ、ログ情報を分析し、プロファイルタグとリアルタイム記録をHbaseに格納する。ユーザーが推薦リクエストを発行した後、ユーザープロファイルに基づいて人気度リストを再ソートし、協調フィルタリングとタグの2つの推薦モジュールを組み合わせて新しく生成されたリストの各商品に関連商品を付与し、最後に新しいユーザーリストを返す。

読者がFlinkコンポーネントを即座に理解できるように焦点を当てたリポジトリ。Flinkの実践コードとドキュメント、200のFlinkチュートリアル知識ポイント、Flink Datastream、Flink Table、Flink Window、Flink State、Flink Checkpoint、Flink Metrics、Flink Memory、Flink on standalone/yarn/k8s、Flink SQL、Flink CEP、Flink CDC、Flink UDF、PyFlink、Flinkの新機能、Flink Partition、Flink Memoryなどの知識ポイントを含みます。詳細リンク：https://mp.weixin.qq.com/mp/appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=getalbum&album_id=2038088622687469575#wechat_redirect

リアルタイムデータの操作を自動化するローコードツール | ユーザー向けストリーム処理。