# 基于 Spark Streaming + ALS 的餐饮推荐系统
## 概述
基于大数据的餐饮推荐系统，整体采用Lambda架构，读取餐饮评分数据并通过Spark的MLlib中的ALS建立推荐模型之后进行推荐。
这里是推荐引擎的代码，分为离线推荐和实时推荐。
## 总结说明
[说明地址](https://www.cnblogs.com/share23/articles/9589239.html)
## 系统流程图
## 最终效果
基于大数据的餐饮推荐系统，整体采用Lambda架构，读取餐饮评分数据并通过Spark的MLlib中的ALS建立推荐模型后进行推荐
版权申诉
5星 · 超过95%的资源 172 浏览量
2022-04-18
15:05:10
上传
评论 12
收藏 132KB ZIP 举报 
基于大数据的餐饮推荐系统，整体采用Lambda架构，读取餐饮评分数据并通过Spark的MLlib中的ALS建立推荐模型后进行推荐 （252个子文件） 
sparktrain.iml 24KB my_scala.iml 535B HBaseUtils.java 3KB LoggerGenerator.java 384B README.md 715B log4j.properties 481B FoodRecommendStreamingApp.scala 6KB CourseClickCountDAO.scala 2KB RatingToHBase.scala 1KB FoodToHBase.scala 1015B UserToHBase.scala 782B DateUtils.scala 626B ClickLog.scala 436B CourseClickCount.scala 306B RatingInfo.scala 148B FoodInfo.scala 131B uiDesigner.xml 9KB pom.xml 6KB Maven__org_scala_lang_scala_library_2_11_8.xml 1KB Maven__org_apache_hadoop_hadoop_mapreduce_client_jobclient_2_6_0_cdh5_7_0.xml 784B Maven__org_apache_hadoop_hadoop_mapreduce_client_shuffle_2_6_0_cdh5_7_0.xml 770B Maven__org_apache_hadoop_hadoop_mapreduce_client_common_2_6_0_cdh5_7_0.xml 763B Maven__org_glassfish_jersey_containers_jersey_container_servlet_core_2_22_2.xml 756B Maven__org_apache_hadoop_hadoop_mapreduce_client_core_2_6_0_cdh5_7_0.xml 749B Maven__org_apache_hadoop_hadoop_mapreduce_client_app_2_6_0_cdh5_7_0.xml 742B Maven__org_apache_hadoop_hadoop_yarn_server_common_2_6_0_cdh5_7_0.xml 728B Maven__org_glassfish_jersey_containers_jersey_container_servlet_2_22_2.xml 721B Maven__org_apache_directory_server_apacheds_kerberos_codec_2_0_0_M15.xml 719B Maven__org_scala_lang_modules_scala_parser_combinators_2_11_1_0_2.xml 713B Maven__com_fasterxml_jackson_module_jackson_module_scala_2_11_2_6_5.xml 709B Maven__org_apache_flume_flume_ng_clients_flume_ng_log4jappender_1_6_0.xml 708B Maven__org_glassfish_hk2_external_aopalliance_repackaged_2_4_0_b34.xml 708B Maven__org_apache_spark_spark_streaming_flume_sink_2_11_2_2_0.xml 703B Maven__com_fasterxml_jackson_module_jackson_module_paranamer_2_6_5.xml 702B Maven__org_apache_spark_spark_streaming_kafka_0_8_2_11_2_2_0.xml 696B Maven__org_apache_hbase_hbase_hadoop2_compat_1_2_0_cdh5_7_0.xml 689B Maven__com_github_stephenc_findbugs_findbugs_annotations_1_3_9_1.xml 688B Maven__org_apache_hbase_hbase_hadoop_compat_1_2_0_cdh5_7_0.xml 682B Maven__org_apache_hadoop_hadoop_yarn_common_2_6_0_cdh5_7_0.xml 679B Maven__org_apache_hadoop_hadoop_yarn_client_2_6_0_cdh5_7_0.xml 679B Maven__org_apache_hadoop_hadoop_annotations_2_6_0_cdh5_7_0.xml 679B Maven__org_mortbay_jetty_jetty_sslengine_6_1_26_cloudera_4.xml 679B Maven__org_glassfish_jersey_bundles_repackaged_jersey_guava_2_22_2.xml 669B Maven__org_apache_hbase_hbase_annotations_1_2_0_cdh5_7_0.xml 668B Maven__org_apache_spark_spark_network_shuffle_2_11_2_2_0.xml 668B Maven__org_apache_hbase_hbase_prefix_tree_1_2_0_cdh5_7_0.xml 668B Maven__org_apache_spark_spark_streaming_flume_2_11_2_2_0.xml 668B Maven__org_apache_hadoop_hadoop_hdfs_test_jar_tests_2_6_0_cdh5_7_0.xml 661B Maven__org_apache_spark_spark_network_common_2_11_2_2_0.xml 661B Maven__com_fasterxml_jackson_core_jackson_annotations_2_6_5.xml 659B Maven__org_apache_hadoop_hadoop_yarn_api_2_6_0_cdh5_7_0.xml 658B Maven__org_apache_hadoop_hadoop_core_2_6_0_mr1_cdh5_7_0.xml 658B Maven__com_github_stephenc_high_scale_lib_high_scale_lib_1_1_1.xml 656B Maven__org_apache_hbase_hbase_common_tests_1_2_0_cdh5_7_0.xml 655B Maven__org_apache_hbase_hbase_procedure_1_2_0_cdh5_7_0.xml 654B Maven__org_glassfish_jersey_media_jersey_media_jaxb_2_22_2.xml 652B Maven__org_apache_htrace_htrace_core4_4_0_1_incubating.xml 651B Maven__org_apache_directory_server_apacheds_i18n_2_0_0_M15.xml 649B Maven__org_apache_hbase_hbase_protocol_1_2_0_cdh5_7_0.xml 647B compiler.xml 645B Maven__commons_beanutils_commons_beanutils_core_1_7_0.xml 644B Maven__org_mortbay_jetty_jetty_util_6_1_26_cloudera_4.xml 644B Maven__org_apache_hadoop_hadoop_common_2_6_0_cdh5_7_0.xml 644B Maven__org_apache_hadoop_hadoop_client_2_6_0_cdh5_7_0.xml 644B Maven__org_apache_htrace_htrace_core_3_2_0_incubating.xml 644B Maven__org_apache_spark_spark_mllib_local_2_11_2_2_0.xml 640B Maven__org_apache_flume_flume_ng_configuration_1_6_0.xml 640B Maven__commons_configuration_commons_configuration_1_6.xml 639B Maven__org_glassfish_hk2_external_javax_inject_2_4_0_b34.xml 638B Maven__com_fasterxml_jackson_core_jackson_databind_2_6_5.xml 638B Maven__org_glassfish_hk2_osgi_resource_locator_1_0_1.xml 637B Maven__org_apache_hbase_hbase_client_1_2_0_cdh5_7_0.xml 633B Maven__org_apache_hbase_hbase_common_1_2_0_cdh5_7_0.xml 633B Maven__org_apache_hbase_hbase_server_1_2_0_cdh5_7_0.xml 633B Maven__commons_collections_commons_collections_3_2_2.xml 631B Maven__org_apache_directory_api_api_asn1_api_1_0_0_M20.xml 630B Maven__org_apache_hadoop_hadoop_auth_2_6_0_cdh5_7_0.xml 630B Maven__org_apache_hadoop_hadoop_hdfs_2_6_0_cdh5_7_0.xml 630B Maven__org_apache_zookeeper_zookeeper_3_4_5_cdh5_7_0.xml 628B Maven__org_codehaus_jackson_jackson_mapper_asl_1_8_8.xml 628B Maven__org_apache_spark_spark_streaming_2_11_2_2_0.xml 626B Maven__javax_validation_validation_api_1_1_0_Final.xml 626B Maven__org_apache_hadoop_hadoop_aws_2_6_0_cdh5_7_0.xml 623B Maven__org_glassfish_jersey_core_jersey_client_2_22_2.xml 620B Maven__org_glassfish_jersey_core_jersey_common_2_22_2.xml 620B Maven__org_glassfish_jersey_core_jersey_server_2_22_2.xml 620B Maven__org_apache_spark_spark_catalyst_2_11_2_2_0.xml 619B Maven__org_apache_spark_spark_launcher_2_11_2_2_0.xml 619B Maven__io_dropwizard_metrics_metrics_graphite_3_1_2.xml 618B Maven__net_sourceforge_f2j_arpack_combined_all_0_1.xml 617B Maven__org_codehaus_jackson_jackson_core_asl_1_8_8.xml 614B Maven__org_apache_curator_curator_framework_2_7_1.xml 613B Maven__javax_annotation_javax_annotation_api_1_2.xml 612B Maven__org_codehaus_janino_commons_compiler_3_0_0.xml 610B Maven__com_fasterxml_jackson_core_jackson_core_2_6_5.xml 610B Maven__commons_beanutils_commons_beanutils_1_7_0.xml 609B Maven__org_mortbay_jetty_jetty_6_1_26_cloudera_4.xml 609B Maven__org_scala_lang_modules_scala_xml_2_11_1_0_2.xml 608B Maven__org_apache_commons_commons_compress_1_4_1.xml 606B Maven__commons_fileupload_commons_fileupload_1_2.xml 606B共 252 条
- 1
- 2
- 3
评论4