240
收录了3920篇文章 ·4311个问题 · 0人关注
0

Livy Server: return a dataframe as JSON?

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: IamexecutingastatementinLivyServerusingHTTPPOSTcalltolocalhost:8998/sessions/0/statements,withthefollowin......

0

SQL query Frequency Distribution matrix for produc

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: iwanttocreateafrequencydistributionmatrix 1.Createamatrix.**Isitpossibletogetthisinseparatecolumns** ......

0

How to filter rows for a specific aggregate with s

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: Normallyallrowsinagrouparepassedtoanaggregatefunction.Iwouldliketofilterrowsusingaconditionsothato......

0

How to name file when saveAsTextFile in spark?

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: Whensavingasatextfileinsparkversion1.5.1Iuse:rdd.saveAsTextFile('<drectory>'). ButifIwanttofindthef......

0

Spark save(write) parquet only one file

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: ifiwrite dataFrame.write.format("parquet").mode("append").save("temp.parquet") intemp.parquetfolder igotthesam.....

0

Could you give me any clue Why 'Cannot call me

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: WhenIputthe'vallines=sc.textFile("hdfs:///input")'inyarn-client,'CannotcallmethodsonastoppedSparkContext......

0

Why does the Spark DataFrame conversion to RDD req

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: FromtheSparksourcecode: /** *RepresentsthecontentoftheDatasetasan`RDD`of`T`. * *@groupbasic ......

0

How do I enable partition pruning in spark

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: IamreadingparquetdataandIseethatitislistingallthedirectoriesondriverside Listings3://xxxx/defloc/wareh......

0

Python spark extract characters from dataframe

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: Ihaveadataframeinspark,somethinglikethis: ID|Column ------|---- 1|STRINGOFLETTERS 2|SOMEOT......

0

Java heap space OutOfMemoryError in pyspark spark-

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: Ihaveadatasetsizeof10GB(exampleTest.txt). Iwrotemypysparkscriptlikebelow(Test.py): frompysparkimportSp......

0

Spark: Programmatically creating dataframe schema

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: IhaveasmallishdatasetthatwillbetheresultofaSparkjob.Iamthinkingaboutconvertingthisdatasettoadatafr......

0

scala.ScalaReflectionException: is not a te

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: IhavethefollowingpieceofcodeinSpark: rdd .map(processFunction(_)) .saveToCassandra("keyspace","tableName") ......

0

How to add multiple columns using UDF?

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: Question IwanttoaddthereturnvaluesofaUDFtoanexistingdataframeinseperatecolumns.HowdoIachievethisin......

0

Spark Write to S3 V4 SignatureDoesNotMatch Error

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: IencounterS3SignatureDoesNotMatchwhiletryingtowriteDataframetoS3withSpark. Thesymptom/thingshavetried: ......

0

Spark EC2 SSH connection error SSH return code 255

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: EverytimeItrytostartaSparkclusteronAWSviatheSparkec2/spark_ec2.pyfileIgetanSSHconnectionerrorthate......

0

ClassNotFoundException: org.apache.spark.SparkConf

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: IamtryingtouseSPARKashiveexecutionengine,butgettingthebelowerror.Spark1.5.0isinstalledandIamworking......

0

Difference and use-cases of RDD and Pair RDD

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: IamnewtosparkandtryingtounderstandthedifferencebetweennormalRDDandapairRDD.Whataretheuse-caseswhere......

0

How to use java.time.LocalDate in Datasets (fails

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: Thisquestionalread...

0

How to create Spark RDD from an iterator?

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: Tomakeitclear,IamnotlookingforRDDfromanarray/listlike List<Integer>list=Arrays.asList(1,2,3,4,5,6,......

0

Lost executor driver on localhost: Executor heartb

可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效,请关闭广告屏蔽插件后再试):问题: Iamdebuggingasparkapplicationinlocalmode.Isitfeasibletodisabletimeoutstoavoidsparkcrashinginthemiddl......