- 18756 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....
- 18756 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
- 37124 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...
- 37124 Views
- 5 replies
- 0 kudos
- 9111 Views
- 5 replies
- 0 kudos
- 9111 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
- 12156 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?
- 12156 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
- 8291 Views
- 3 replies
- 0 kudos
Get last modified date or create date for azure blob container
Hi Everyone, I am trying to implement a way in Python to only read files that weren't loaded since the last run of my notebook. The way I am thinking of implementing this is to keep of the last time my notebook has finished in a database table. Nex...
- 8291 Views
- 3 replies
- 0 kudos
- 0 kudos
Hello! I just wanted to share my point of view on the topic of dating sites. I have been looking for a decent Asian catch-up site for a very long time, in addition to them I found https://hookupsearch.org/asian-hookup-sites/. We definitely recommend...
- 0 kudos
- 22570 Views
- 5 replies
- 3 kudos
com.databricks.sql.io.FileReadException: Error while reading file dbfs:
I ran the below statement and got the error %python data = sqlContext.read.parquet("/FileStore/tables/ganesh.parquet") display(data) Error: SparkException: Job aborted due to stage failure: Task 0 in stage 27.0 failed 1 times, most recent failure:...
- 22570 Views
- 5 replies
- 3 kudos
- 3 kudos
I'm having a similar issue reading a JSON file. It is ~550MB compressed and is on a single line: val cfilename = "c_datafeed_20200128.json.gz" val events = spark.read.json(s"/mnt/c/input1/$cfilename") display(events) The filename is correct and t...
- 3 kudos
- 13951 Views
- 2 replies
- 1 kudos
FileNotFoundError: [Errno 2] No such file or directory or IsADirectoryError: [Errno 21] Is a directory
I have been trying to open a file on the dbfs using all different combinations: if I use the following code: with open("/dbfs/FileStore/df/Downloadedfile.csv", 'r', newline='') as f I get IsADirectoryError: [Errno 21] Is a directory with open("dbfs:...
- 13951 Views
- 2 replies
- 1 kudos
- 1 kudos
To get rid of this error you can try using Python file exists methods to check that at least python sees the file exists or not. In other words, you can make sure that the user has indeed typed a correct path for a real existing file. If the user do...
- 1 kudos
- 8227 Views
- 3 replies
- 1 kudos
Resolved! JavaPackage' object is not callable :: Mlean
Hi Folks, We are working on production Databricks project using Mleap. when run below code on databricks, it throws error like " 'JavaPackage' object is not callable" code :import mleap.pyspark from mleap.pyspark.spark_support import SimpleSparkSer...
- 8227 Views
- 3 replies
- 1 kudos
- 22563 Views
- 10 replies
- 0 kudos
Resolved! How to convert column type from decimal to date in sparksql
I need to convert column type from decimal to date in sparksql when the format is not yyyy-mm-dd? A table contains column data declared as decimal (38,0) and data is in yyyymmdd format and I am unable to run sql queries on it in databrick notebook. ...
- 22563 Views
- 10 replies
- 0 kudos
- 26608 Views
- 5 replies
- 2 kudos
Resolved! How to display SHAP plots?
I am looking to display SHAP plots, here is the code:import xgboost import shap shap.initjs() # load JS visualization code to notebookX,y = shap.datasets.boston() # train XGBoost model model = xgboost.train({"learning_rate": 0.01}, xgboost.DMatri...
- 26608 Views
- 5 replies
- 2 kudos
- 2 kudos
As @Vinh dqvinh87​ noted, the accepted solution only works for force_plot. For other plots, the following trick works for me:import matplotlib.pyplot as plt p = shap.summary_plot(shap_values, test_df, show=False) display(p)
- 2 kudos
- 18275 Views
- 3 replies
- 0 kudos
KNN classifier on Spark
Hi Team , Can you please help me in implementing KNN classifer in pyspark using distributed architecture and processing the dataset. Even I want to validate the KNN model with the testing dataset. I tried to use scikit learn but the program is runn...
- 18275 Views
- 3 replies
- 0 kudos
- 0 kudos
Hey, about about using NEC Frovedis (https://github.com/frovedis/frovedis) framework for the same. Refer: https://github.com/frovedis/frovedis/blob/master/src/foreign_if/python/examples/unsupervised_knn_demo.py It works on a distributed framework (...
- 0 kudos
- 26889 Views
- 1 replies
- 0 kudos
How can I read all the files in a folder on S3 into several pandas dataframes?
import pandas as pd import glob path = "s3://somewhere/" # use your path all_files = glob.glob(path + "/*.csv") print(all_files) li = [] for filename in all_files: dfi = pd.read_csv(filename,names =['acct_id', 'SOR_ID'], dtype={'acct_id':str,...
- 26889 Views
- 1 replies
- 0 kudos
- 0 kudos
Hi @zhaoxuan210, Please go through the below answer,https://stackoverflow.com/questions/52855221/reading-multiple-csv-files-from-s3-bucket-with-boto3
- 0 kudos
- 10947 Views
- 6 replies
- 0 kudos
- 10947 Views
- 6 replies
- 0 kudos
- 0 kudos
Hello, What is most efficient between RDD and DataFrame ? (I mean better to cache, consume less memory) Thanks you,
- 0 kudos
- 51007 Views
- 5 replies
- 3 kudos
What's the difference between Interactive Clusters and Job Cluster?
I am new to databricks. I would like to know what is the difference between Interactive Clusters and Job Cluster? There are no official document now.
- 51007 Views
- 5 replies
- 3 kudos
- 3 kudos
Sports news Football news International football news Football news Thai football news, Thai football Follow news, know sports news at Siamsportnews
- 3 kudos
- 30622 Views
- 9 replies
- 1 kudos
How can I change the parquet compression algorithm from gzip to something else?
Spark, by default, uses gzip to store parquet files. I would like to change the compression algorithm from gzip to snappy or lz4.
- 30622 Views
- 9 replies
- 1 kudos
| User | Count |
|---|---|
| 1645 | |
| 793 | |
| 584 | |
| 349 | |
| 287 |
