Python Playground

I'm trying to write a simple pyspark job, which would receive data from a kafka broker topic, d… Read more How To Properly Use Pyspark To Send Data To Kafka Broker?

I am having 100,000+ of records in dataframe. I want to create a file dynamically and push 1000 rec… Read more How To Get 1000 Records From Dataframe And Write Into A File Using Pyspark?

I have a PySpark DataFrame and I have tried many examples showing how to create a new column based … Read more Pyspark - Create New Column From Operations Of Dataframe Columns Gives Error "column Is Not Iterable"

I have a list of valid values that a cell can have. If one cell in a column is invalid, I need to d… Read more How To Drop Columns Based On Multiple Filters In A Dataframe Using Pyspark?

I've seen (here: How to convert Timestamp to Date format in DataFrame?) the way to convert a ti… Read more Convert Timestamp To Date In Spark Dataframe

For example, I have one full set of nested JSON, I need to update this JSON with the latest values … Read more Update The Nested Json With Another Nested Json Using Python