文件名称：特殊的傻笑
文件大小：1.11MB
文件格式：ZIP
更新时间：2024-03-07 07:51:53
Python
SF犯罪事件分析 档案资讯 snapshots.zip包含快照。 producer_server.py data_stream.py kafka_server.py Q1。 更改SparkSession属性参数的值如何影响数据的吞吐量和延迟？ 更改已处理的行数（processedRowsPerSecond / inputRowsPerSecond）对数据的吞吐量和延迟有直接影响。 Q2。 2-3个最有效的SparkSession属性键/值对是什么？ 通过测试值的多种变化，您如何分辨出它们是最佳的？ 实验了spark.sql.shuffle.partitions值从2到20的情况，发现processingRowsPerSecond最好为2。 对spark.default.parallelism值进行了实验，发现加工的行数在较小的值上更好。 Kafka使用者控制台输出 Spark工
【文件预览】：
special-giggle-main
----consumer_server.py(916B)
----kafka_server.py(521B)
----data_stream.py(4KB)
----kafka-consumer-console-output.png(274KB)
----spark-job-progress-report.png(118KB)
----README.md(1KB)
----config()
--------zookeeper.properties(1KB)
--------server.properties(5KB)
----producer_server.py(996B)
----spark-streaming-ui.png(233KB)
----snapshots.zip(564KB)