water8394/flink-recommandSystem-demo

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