Fork me on GitHub

Pyspark系列文章-通过toree项目使用Pyspark

目录

  • 背景

  • 第一部分 Receiver接口模式

  • 第二部分 Direct接口模式

  • 第三部分 PySpark和Kafka交互

  • 第四部分 任务提交

  • 参考文献及资料

背景

第一部分 安装toree

1
# pip install toree

安装

1
# jupyter toree install --spark_home=/opt/spark-2.3.2/

参考文献及资料

1、Improvements to Kafka integration of Spark Streaming,

0%