<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.supermy</groupId>
<artifactId>stream-sql</artifactId>
<version>0.1.0</version>
<!-- 注意:这里scala的版本要和自己电脑上安装的scala一致,而且要注意spark对应的版本是否支持scala对应的版本。否则会存在版本冲突问题 -->
<properties>
<spark.version>1.6.1</spark.version>
<scala.version>2.11</scala.version>
</properties>
<dependencies>
<!--<dependency>-->
<!--<groupId>org.apache.spark</groupId>-->
<!--<artifactId>spark-hive_${scala.version}</artifactId>-->
<!--<version>${spark.version}</version>-->
<!--</dependency>-->
<!--<dependency>-->
<!--<groupId>org.apache.spark</groupId>-->
<!--<artifactId>spark-mllib_${scala.version}</artifactId>-->
<!--<version>${spark.version}</version>-->
<!--</dependency>-->
<!-- https://mvnrepository.com/artifact/com.google.code.gson/gson -->
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.2</version>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.8.2</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
<version>2.4.2</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_${scala.version}</artifactId>
<version>${spark.version}</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming_${scala.version}</artifactId>
<version>${spark.version}</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-sql_${scala.version}</artifactId>
<version>${spark.version}</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming-kafka_${scala.version}</artifactId>
<version>${spark.version}</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.scala-tools</groupId>
<artifactId>maven-scala-plugin</artifactId>
<version>2.15.2</version>
<executions>
<execution>
<goals>
<goal>compile</goal>
<goal>testCompile</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.6.0</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.19</version>
<configuration>
<skip>true</skip>
</configuration>
</plugin>
</plugins>
</build>
</project>
没有合适的资源?快使用搜索试试~ 我知道了~
大数据实时流的计算框架,kafka+spark+redis,确保 spark所使用的scala版本与你系统scala的版本一致
共167个文件
xml:160个
scala:5个
md:1个
1.该资源内容由用户上传,如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
版权申诉
0 下载量 80 浏览量
2023-05-31
16:10:17
上传
评论
收藏 86KB ZIP 举报
温馨提示
大数据实时流的计算框架,kafka+spark+redis,确保 spark所使用的scala版本与你系统scala的版本一致;实时计算,窗口框架计算,Spark 调用Redis采用单例+pipeline ,性能比普通模式提升10倍,适用场景,时间片段数量统计 时间片段筛选。优势:kafka 大数据量传输优势,spark 时间窗的灵活计算,redis 基于内存的定制计算
资源推荐
资源详情
资源评论
收起资源包目录
大数据实时流的计算框架,kafka+spark+redis,确保 spark所使用的scala版本与你系统scala的版本一致 (167个子文件)
kafka-spark-redis.iml 16KB
CHANGELOG.md 175B
UserClickCountAnalytics.scala 4KB
KafkaWordCount.scala 2KB
KafkaEventProducer.scala 2KB
KafkaWordCountProducer.scala 2KB
RedisClient.scala 541B
pom.xml 4KB
misc.xml 1KB
compiler.xml 1KB
Maven__org_scala_lang_scala_library_2_11_7.xml 1008B
Maven__com_sun_jersey_jersey_test_framework_jersey_test_framework_grizzly2_1_9.xml 747B
Maven__com_sun_jersey_jersey_test_framework_jersey_test_framework_core_1_9.xml 719B
Maven__org_apache_hadoop_hadoop_mapreduce_client_jobclient_2_2_0.xml 706B
Maven__org_scala_lang_modules_scala_parser_combinators_2_11_1_0_2.xml 698B
Maven__com_fasterxml_jackson_module_jackson_module_scala_2_11_2_4_4.xml 694B
Maven__org_apache_hadoop_hadoop_mapreduce_client_shuffle_2_2_0.xml 692B
Maven__org_eclipse_jetty_orbit_javax_servlet_3_0_0_v201112011016.xml 688B
Maven__org_apache_hadoop_hadoop_mapreduce_client_common_2_2_0.xml 685B
Maven__org_apache_hadoop_hadoop_mapreduce_client_core_2_2_0.xml 671B
Maven__org_apache_hadoop_hadoop_mapreduce_client_app_2_2_0.xml 664B
Maven__org_apache_parquet_parquet_format_2_3_0_incubating.xml 654B
Maven__org_apache_spark_spark_streaming_kafka_2_11_1_6_1.xml 653B
Maven__org_apache_spark_spark_network_shuffle_2_11_1_6_1.xml 653B
Maven__org_apache_hadoop_hadoop_yarn_server_common_2_2_0.xml 650B
Maven__org_apache_spark_spark_network_common_2_11_1_6_1.xml 646B
Maven__com_fasterxml_jackson_core_jackson_annotations_2_4_4.xml 644B
Maven__org_glassfish_grizzly_grizzly_http_servlet_2_1_2.xml 631B
Maven__commons_beanutils_commons_beanutils_core_1_8_0.xml 629B
Maven__org_glassfish_external_management_api_3_0_0_b012.xml 628B
Maven__org_tachyonproject_tachyon_underfs_local_0_8_2.xml 626B
Maven__commons_configuration_commons_configuration_1_6.xml 624B
Maven__org_glassfish_grizzly_grizzly_http_server_2_1_2.xml 624B
Maven__com_fasterxml_jackson_core_jackson_databind_2_4_4.xml 623B
Maven__org_codehaus_jackson_jackson_mapper_asl_1_9_13.xml 620B
Maven__org_tachyonproject_tachyon_underfs_hdfs_0_8_2.xml 619B
Maven__commons_collections_commons_collections_3_2_1.xml 616B
Maven__org_glassfish_gmbal_gmbal_api_only_3_0_0_b023.xml 616B
Maven__org_apache_spark_spark_streaming_2_11_1_6_1.xml 611B
Maven__org_glassfish_grizzly_grizzly_framework_2_1_2.xml 610B
Maven__com_esotericsoftware_reflectasm_reflectasm_shaded_1_07.xml 608B
Maven__org_codehaus_jackson_jackson_core_asl_1_9_13.xml 606B
Maven__org_tachyonproject_tachyon_underfs_s3_0_8_2.xml 605B
Maven__org_apache_spark_spark_catalyst_2_11_1_6_1.xml 604B
Maven__org_apache_spark_spark_launcher_2_11_1_6_1.xml 604B
Maven__io_dropwizard_metrics_metrics_graphite_3_1_2.xml 603B
Maven__org_apache_hadoop_hadoop_yarn_common_2_2_0.xml 601B
Maven__org_apache_hadoop_hadoop_yarn_client_2_2_0.xml 601B
Maven__org_apache_hadoop_hadoop_annotations_2_2_0.xml 601B
Maven__org_apache_curator_curator_framework_2_4_0.xml 598B
Maven__org_apache_parquet_parquet_generator_1_7_0.xml 598B
Maven__org_uncommons_maths_uncommons_maths_1_2_2a.xml 595B
Maven__org_codehaus_janino_commons_compiler_2_7_8.xml 595B
Maven__com_fasterxml_jackson_core_jackson_core_2_4_4.xml 595B
Maven__com_typesafe_akka_akka_remote_2_11_2_3_11.xml 594B
Maven__commons_beanutils_commons_beanutils_1_7_0.xml 594B
Maven__org_scala_lang_modules_scala_xml_2_11_1_0_2.xml 593B
Maven__org_apache_commons_commons_compress_1_4_1.xml 591B
Maven__org_fusesource_leveldbjni_leveldbjni_all_1_8.xml 591B
Maven__org_apache_parquet_parquet_encoding_1_7_0.xml 591B
Maven__commons_httpclient_commons_httpclient_3_1.xml 591B
Maven__org_apache_spark_spark_unsafe_2_11_1_6_1.xml 590B
Maven__com_typesafe_akka_akka_slf4j_2_11_2_3_11.xml 587B
Maven__org_json4s_json4s_jackson_2_11_3_2_10.xml 587B
Maven__com_typesafe_akka_akka_actor_2_11_2_3_11.xml 587B
Maven__org_apache_parquet_parquet_jackson_1_7_0.xml 584B
Maven__org_apache_curator_curator_recipes_2_4_0.xml 584B
Maven__org_apache_hadoop_hadoop_yarn_api_2_2_0.xml 580B
Maven__javax_servlet_javax_servlet_api_3_0_1.xml 578B
Maven__org_codehaus_jackson_jackson_jaxrs_1_8_3.xml 578B
Maven__org_apache_parquet_parquet_common_1_7_0.xml 577B
Maven__org_apache_parquet_parquet_hadoop_1_7_0.xml 577B
Maven__org_tachyonproject_tachyon_client_0_8_2.xml 577B
Maven__org_apache_curator_curator_client_2_4_0.xml 577B
Maven__org_apache_parquet_parquet_column_1_7_0.xml 577B
Maven__org_apache_spark_spark_core_2_11_1_6_1.xml 576B
Maven__org_apache_xbean_xbean_asm5_shaded_4_4.xml 576B
Maven__org_apache_kafka_kafka_clients_0_8_2_1.xml 576B
Maven__io_dropwizard_metrics_metrics_json_3_1_2.xml 575B
Maven__org_glassfish_grizzly_grizzly_http_2_1_2.xml 575B
Maven__io_dropwizard_metrics_metrics_core_3_1_2.xml 575B
Maven__com_google_protobuf_protobuf_java_2_5_0.xml 574B
Maven__org_roaringbitmap_RoaringBitmap_0_5_11.xml 573B
Maven__org_apache_commons_commons_lang3_3_3_2.xml 570B
Maven__org_apache_commons_commons_pool2_2_4_2.xml 570B
Maven__org_apache_commons_commons_math3_3_4_1.xml 570B
Maven__com_sun_jersey_contribs_jersey_guice_1_9.xml 569B
Maven__commons_digester_commons_digester_1_8.xml 569B
Maven__org_apache_spark_spark_sql_2_11_1_6_1.xml 569B
Maven__org_glassfish_grizzly_grizzly_rcm_2_1_2.xml 568B
Maven__org_scala_lang_scala_compiler_2_11_0.xml 568B
Maven__io_dropwizard_metrics_metrics_jvm_3_1_2.xml 568B
Maven__org_json4s_json4s_core_2_11_3_2_10.xml 566B
Maven__org_apache_hadoop_hadoop_client_2_2_0.xml 566B
Maven__org_apache_hadoop_hadoop_common_2_2_0.xml 566B
Maven__com_yammer_metrics_metrics_core_2_2_0.xml 563B
Maven__org_scala_lang_scala_reflect_2_11_2.xml 561B
Maven__com_thoughtworks_paranamer_paranamer_2_6.xml 560B
Maven__org_apache_avro_avro_mapred_hadoop2_1_7_7.xml 560B
Maven__org_json4s_json4s_ast_2_11_3_2_10.xml 559B
共 167 条
- 1
- 2
资源评论
Java程序员-张凯
- 粉丝: 1w+
- 资源: 7288
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功