water8394/flink-recommandSystem-demo

:helicopter::rocket: Echtzeit-Produktempfehlungssystem auf Basis von Flink. Flink ermittelt die Produkthotness, speichert sie in einem Redis-Cache und analysiert Protokolldaten, um Profil-Tags und Echtzeitdatensätze in HBase abzulegen. Nach einer Empfehlungsanfrage des Benutzers wird die Hotness-Liste basierend auf dem Benutzerprofil neu sortiert. Zudem werden kollaborative Filterung und Tag-Module genutzt, um jedem Produkt der neu generierten Liste verknüpfte Produkte hinzuzufügen, bevor die finale Benutzerliste zurückgegeben wird.