Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-spark

Why is my Spark App running in only 1 executor?

Spark UDAF: java.lang.InternalError: Malformed class name

dynamically changing library dependencies in sbt build file from provided etc

Drop first row of Spark DataFrame

Towards limiting the big RDD

How can I know spark-core version?

Is python smart enough to replace function calls with constant result?

How to load table from SQLLite db file from PySpark?

assertion failed: unsafe symbol DeveloperApi in runtime reflection universe

java scala apache-spark

How to use ReduceByKey on multiple key in a Scala Spark Job

Is there any means to serialize custom Transformer in Spark ML Pipeline

Is it possible to set global variables in a Zeppelin Notebook?

Does Spark write intermediate shuffle outputs to disk

apache-spark rdd

spark - How to reduce the shuffle size of a JavaPairRDD<Integer, Integer[]>?

java scala apache-spark kryo

Spark: How to delete a specific variable from spark-shell memory namespace?

scala apache-spark

what is raw prediction in Logistic Regression in spark mllib?

Setup and configuration of JanusGraph for a Spark cluster and Cassandra

How to start Spark Thrift Server on Datastax Enterprise (fails with java.lang.NoSuchMethodError: ...LogDivertAppender.setWriter)?

How to set Kafka parameters from a properties file?

How to map rows to protobuf-generated class?