Building our first Spark Streaming Application! | PySpark Tutorial

In this lecture, we're going to build our first Spark Streaming Application which will listen to the socket connection for any incoming data and count the words and provide us the aggregated output.
Links/codes required for this lecture:
Install NCAT tool: nmap.org/dist/nmap-7.92-setup...
PySpark Streaming code:
github.com/ashaypatil11/hadoo...
-------------------------------------------------------------------------------------------------------------
Anaconda Distributions Installation link:
www.anaconda.com/products/dis...
----------------------------------------------------------------------------------------------------------------------
PySpark installation steps on MAC: sparkbyexamples.com/pyspark/h...
Apache Spark Installation links:
1. Download JDK: www.oracle.com/in/java/techno...
2. Download Python: www.python.org/downloads/
3. Download Spark: spark.apache.org/downloads.html
Environment Variables:
HADOOP_HOME- C:\hadoop
JAVA_HOME- C:\java\jdk
SPARK_HOME- C:\spark\spark-3.3.1-bin-hadoop2
PYTHONPATH- %SPARK_HOME%\python;%SPARK_HOME%\python\lib\py4j-0.10.9-src;%PYTHONPATH%
Required Paths:
%SPARK_HOME%\bin
%HADOOP_HOME%\bin
%JAVA_HOME%\bin
Also check out our full Apache Hadoop course:
• Big Data Hadoop Full C...
----------------------------------------------------------------------------------------------------------------------
Apache Spark Installation links:
1. Download JDK: www.oracle.com/in/java/techno...
2. Download Python: www.python.org/downloads/
3. Download Spark: spark.apache.org/downloads.html
Also check out similar informative videos in the field of cloud computing:
What is Big Data: • What is Big Data? | Bi...
How Cloud Computing changed the world: • How Cloud Computing ch...
What is Cloud? • What is Cloud Computing?
Top 10 facts about Cloud Computing that will blow your mind! • Top 10 facts about Clo...
Audience
This tutorial has been prepared for professionals/students aspiring to learn deep knowledge of Big Data Analytics using Apache Spark and become a Spark Developer and Data Engineer roles. In addition, it would be useful for Analytics Professionals and ETL developers as well.
Prerequisites
Before proceeding with this full course, it is good to have prior exposure to Python programming, database concepts, and any of the Linux operating system flavors.
-----------------------------------------------------------------------------------------------------------------------
Check out our full course topic wise playlist on some of the most popular technologies:
SQL Full Course Playlist-
• SQL Full Course
PYTHON Full Course Playlist-
• Python Full Course
Data Warehouse Playlist-
• Data Warehouse Full Co...
Unix Shell Scripting Full Course Playlist-
• Unix Shell Scripting F...
-----------------------------------------------------------------------------------------------------------------------Don't forget to like and follow us on our social media accounts:
Facebook-
/ ampcode
Instagram-
/ ampcode_tutorials
Twitter-
/ ampcodetutorial
Tumblr-
ampcode.tumblr.com
-----------------------------------------------------------------------------------------------------------------------
Channel Description-
AmpCode provides you e-learning platform with a mission of making education accessible to every student. AmpCode will provide you tutorials, full courses of some of the best technologies in the world today. By subscribing to this channel, you will never miss out on high quality videos on trending topics in the areas of Big Data & Hadoop, DevOps, Machine Learning, Artificial Intelligence, Angular, Data Science, Apache Spark, Python, Selenium, Tableau, AWS , Digital Marketing and many more.
#pyspark #bigdata #datascience #dataanalytics #datascientist #spark #dataengineering #apachespark

[@abdullahyahya2471]

Perfectly structured Video. Thanks.

[@ampcode]

Glad it was helpful!

[@sanooosai]

great thank you

[@vivianhuang7670]

I followed this run the whole script, but same with vscode, it's not showing anything...it's like my execution just stuck after one warning msg: 23/12/29 15:44:07 WARN ResolveWriteToStream: spark.sql.adaptive.enabled is not supported in streaming DataFrames/Datasets and will be disabled... May I know why?

[@QuangHuy-is7jo]

you can change to pycharm, i tried and succeeded

[@pratibhakoli4047]

Sir I have project base on spark i.e. real time wether forcast using spark streaming. So how can I start this project.

[@pratibhakoli4047]

Any material or udemy courses to complete that one

[@ampcode]

Sorry for late reply. Thanks for your suggestion and I would really like to do this project once we'll complete all this basic stuff. Thanks again!

[@pratibhakoli4047]

Ok sir

[@hamnakhalidbutt7166]

# Start streaming defining the necessary configurations streamingQuery = (counts .writeStream .format("console") .outputMode("complete") .trigger(processingTime="1 second") .option("checkpointLocation", checkpointDir) .start()) streamingQuery.awaitTermination()......This step is not executing as there is an issue with starting the streaming query .there is checkpoint directory in C drive and The specific error code "exitCode=-1073741515" indicates a problem with the Hadoop file system permissions.Could you please make any suggestion?

[@ampcode]

Sorry for late response. Could you please check if you have created the checkpoint directory and spark is able to access it?

[@vigneshpillai5360]

Facing same issue. checkpoint directory is created but getting "py4j.protocol.Py4JJavaError: An error occurred while calling o76.start." error and exitCode as ": ExitCodeException exitCode=-1073741515:".

[@atv8992]

@@vigneshpillai5360 yours might be because of directory path

[@daleo156]

🌟 'promosm'