Note 01 1 of 4
Spark Dataframe window function
scala ref create dataframe
Collection
Learn DataFrame operations, SQL tuning, Spark optimization, and structured streaming.
scala ref create dataframe
Configure Spark SQL and tune distributed queries for more efficient execution.
PROCESSLOCAL data is in the same JVM as the running code. This is the best locality possible NODELOCAL data is on the same node. Examples might be in HDFS on the same node, or in another executor on the same node. This is a little slower than PROCESSLOCAL because the data has to travel between...
Recently reading a blog Structured Streaming in PySpark It's implemented in Databricks platform. Then I try to implement in my local Spark. Some tricky issue happened during my work.