Skip to content Skip to sidebar Skip to footer
Showing posts with the label Apache Spark

Numpy And Static Linking

I am running Spark programs on a large cluster (for which, I do not have administrative privileges)… Read more Numpy And Static Linking

Rdd Collect Issue

I configured a new system, spark 2.3.0, python 3.6.0, dataframe read and other operations working a… Read more Rdd Collect Issue

Is It Possible To Scale Data By Group In Spark?

I want to scale data with StandardScaler (from pyspark.mllib.feature import StandardScaler), by now… Read more Is It Possible To Scale Data By Group In Spark?

Spark-submit Fails To Detect The Installed Modulus In Pip

I have a python code which have the following 3rd party dependencies: import boto3 from warcio.arch… Read more Spark-submit Fails To Detect The Installed Modulus In Pip

Python Spark Dataframe: Replace Null With Sparsevector

In spark, I have following data frame called 'df' with some null entries: +-------+--------… Read more Python Spark Dataframe: Replace Null With Sparsevector

Spark Java Error: Size Exceeds Integer.max_value

I am trying to use spark for some simple machine learning task. I used pyspark and spark 1.2.0 to d… Read more Spark Java Error: Size Exceeds Integer.max_value

Pyspark Parse Fixed Width Text File

Trying to parse a fixed width text file. my text file looks like the following and I need a row i… Read more Pyspark Parse Fixed Width Text File

Distributing Python Module - Spark Vs Process Pools

I've made a Python module that extracts handwritten text from PDFs. The extraction can sometime… Read more Distributing Python Module - Spark Vs Process Pools