- 10227 Views
- 7 replies
- 0 kudos
Pyspark. How to get best params in grid search
Hello!I am using spark 2.1.1 in python(python 2.7 executed in jupyter notebook)And trying to make grid search for linear regression parameters.My code looks like this:from pyspark.ml.tuning import CrossValidator, ParamGridBuilder from pyspark.ml impo...
- 10227 Views
- 7 replies
- 0 kudos
- 0 kudos
This is a great article. It gave me a lot of useful information. thank you very much download app
- 0 kudos
- 15370 Views
- 2 replies
- 0 kudos
Resolved! Error of "name 'IntegerType' is not defined" in attempting to convert a DF column to IntegerType
initialDF .withColumn("OriginalCol", initialDF.OriginalCol.cast(IntegerType)) Or initialDF .withColumn("OriginalCol", initialDF.OriginalCol.cast(IntegerType())) However, always failed with this error : NameError: name 'IntegerType' is not defined ...
- 15370 Views
- 2 replies
- 0 kudos
- 26507 Views
- 2 replies
- 0 kudos
Resolved! I need to edit my parquet files, and change field name, replacing space by underscore
Hello, I am facing trouble as mentioned in following topics in stackoverflow, https://stackoverflow.com/questions/45804534/pyspark-org-apache-spark-sql-analysisexception-attribute-name-contains-inv https://stackoverflow.com/questions/38191157/spark-...
- 26507 Views
- 2 replies
- 0 kudos
- 0 kudos
One option is to use something other than Spark to read the problematic file, e.g. Pandas, if your file is small enough to fit on the driver node (Pandas will only run on the driver). If you have multiple files - you can loop through them and fix on...
- 0 kudos
- 11927 Views
- 1 replies
- 0 kudos
Drop duplicates in Table
Hi, there is a function to delete data from a Delta Table: deltaTable = DeltaTable.forPath(spark, "/data/events/") deltaTable.delete(col("date") < "2017-01-01") But is there also a way to drop duplicates somehow? Like deltaTable.dropDuplicates()......
- 11927 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @Christian Hofstetter, You can check here for info on the same,https://docs.delta.io/0.4.0/delta-update.html#data-deduplication-when-writing-into-delta-tables
- 0 kudos
- 6495 Views
- 3 replies
- 0 kudos
OPTIMIZE error: org.apache.spark.sql.catalyst.parser.ParseException: mismatched input 'OPTIMIZE'
Hi everyone. I am trying to learn the keyword OPTIMIZE from this blog using scala: https://docs.databricks.com/delta/optimizations/optimization-examples.html#delta-lake-on-databricks-optimizations-scala-notebook. But my local spark seems not able t...
- 6495 Views
- 3 replies
- 0 kudos
- 0 kudos
Hi Jigao, OPTIMIZE isn't in the open source delta API, so won't run on your local Spark instance - https://docs.delta.io/latest/api/scala/io/delta/tables/index.html?search=optimize
- 0 kudos
- 13464 Views
- 2 replies
- 0 kudos
!pip install vs. dbutils.library.installPyPI()
Hello, Scenario: Trying to install some python modules into a notebook (scoped to just the notebook) using...``` dbutils.library.installPyPI("azure-identity") dbutils.library.installPyPI("azure-storage-blob") dbutils.library.restartPython()``` ...ge...
- 13464 Views
- 2 replies
- 0 kudos
- 0 kudos
Hi @ericOnline I also faced the same issue and I eventually found that upgrading the databricks runtime version from my current "5.5 LTS (includes Apache Spark 2.4.3, Scala 2.11)" to "6.5(Scala 2.11,Spark 2.4.5) resolved this issue. Though the offic...
- 0 kudos
- 42801 Views
- 15 replies
- 0 kudos
Resolved! I am running simple count and I am getting an error
Here is the error that I am getting when I run the following query statement=sqlContext.sql("SELECT count(*) FROM ARDATA_2015_09_01").show() ---------------------------------------------------------------------------Py4JJavaError Traceback (most rec...
- 42801 Views
- 15 replies
- 0 kudos
- 0 kudos
192.168.o.1 is a private IP address used to login the admin panel of a router. 192.168.l.l is the host address to change default router settings.
- 0 kudos
- 7959 Views
- 1 replies
- 0 kudos
Get Size of a column in Bytes for a Pyspark Data frame
Hello All, I have a column in a dataframe which i struct type.I want to find the size of the column in bytes.it is getting failed while loading in snowflake.I could see size functions avialable to get the length.how to calculate the size in bytes fo...
- 7959 Views
- 1 replies
- 0 kudos
- 0 kudos
There isn't one size for a column; it takes some amount of bytes in memory, but a different amount potentially when serialized on disk or stored in Parquet. You can work out the size in memory from its data type; an array of 100 bytes takes 100 byte...
- 0 kudos
- 12716 Views
- 3 replies
- 1 kudos
Resolved! I want to create a function in azure Databricks notebook to send a email, based on a filter. Any leads are appriciated.
I have no idea from where to start
- 12716 Views
- 3 replies
- 1 kudos
- 1 kudos
Thanks for you help @leedabee. I will go through second option, First one is not applicable in my case.
- 1 kudos
- 12267 Views
- 1 replies
- 1 kudos
How to handle Blank values in Array of struct elements in pyspark
Hello All, We have a data in a column in pyspark dataframe having array of struct typehaving multiple nested fields present.if the value is not blank it will savethe data in the same array of struct type in spark delta table.please advise on the bel...
- 12267 Views
- 1 replies
- 1 kudos
- 1 kudos
Hi @Anbazhagan anbutech17,Can you please try as in below answers,https://stackoverflow.com/questions/56942683/how-to-add-null-columns-to-complex-array-struct-in-spark-with-a-udf
- 1 kudos
- 7649 Views
- 1 replies
- 0 kudos
How to resolve our of memory error?
I have a data bricks notebook hosted on Azure. I am having this problem when doing INNER JOIN. I tried creating a much higher cluster configuration but it still making outOfMemoryError. org.apache.spark.memory.SparkOutOfMemoryError: Unable to acquir...
- 7649 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @Juan Miguel Trinidad,can you please the below suggestions,http://apache-spark-developers-list.1001551.n3.nabble.com/java-lang-OutOfMemoryError-Unable-to-acquire-bytes-of-memory-td16773.html
- 0 kudos
- 14698 Views
- 3 replies
- 0 kudos
PySpark DataFrame: Select all but one or a set of columns
In SQL select, in some implementation, we can provide select -col_A to select all columns except the col_A. I tried it in the Spark 1.6.0 as follows: For a dataframe df with three columns col_A, col_B, col_C df.select('col_B, 'col_C') # it works df....
- 14698 Views
- 3 replies
- 0 kudos
- 0 kudos
@sk777, @zjffdu, @Lejla Metohajrova if your columns are time-series ordered OR you want to maintain their original order... use cols = [c for c in df.columns if c != 'col_A'] df[cols]
- 0 kudos
- 33525 Views
- 5 replies
- 0 kudos
Listing all files under an Azure Data Lake Gen2 container
I am trying to find a way to list all files in an Azure Data Lake Gen2 container. I have mounted the storage account and can see the list of files in a folder (a container can have multiple level of folder hierarchies) if I know the exact path of th...
- 33525 Views
- 5 replies
- 0 kudos
- 7281 Views
- 5 replies
- 0 kudos
- 7281 Views
- 5 replies
- 0 kudos
- 0 kudos
I am trying to store a dataframe as table in databricks and encountering the following error, can someone help? "typeerror: field date: can not merge type <class 'pyspark.sql.types.stringtype'> and <class 'pyspark.sql.types.doubletype'>"
- 0 kudos
- 10111 Views
- 6 replies
- 0 kudos
how to remove empty rows from the data frame.
lets assume if i have 10 columns in a data frame,all 10 columns has empty values for 100 rows out of 200 rows, how i can skip the empty rows?
- 10111 Views
- 6 replies
- 0 kudos
- 0 kudos
you can try this: df.na.drop(how = "all"), this will remove the row only if all the rows are null or NaN
- 0 kudos
| User | Count |
|---|---|
| 1619 | |
| 790 | |
| 477 | |
| 349 | |
| 287 |
