Programming, Scala

Call by Name vs Call by Value in Scala

This information is based on the coursera course “Functional Programming Principles in Scala” by Martin Odersky. In Scala expressions* are evaluated by the Scala interpreter following the substitution model. What […]

Spark

Spark Streaming

Here is an example of how to do a very simple streaming from and to file with pyspark. https://gist.github.com/sallos-cyber/a14e03da49cc0c873a651628dba4d096

Spark

SPARK configuration

spark.dynamicAllocation.enabled spark.dynamicAllocation.initialExecutors spark.dynamicAllocation.minExecutors spark.dynamicAllocation.maxExecutors spark.shuffle.partitions spark.default.parallelism = spark.executor.instances * spark.executor.cores * 2 maxPartitionBytes Input bytes = 40 GB? Wähle so viele Partitions, so dass die Größe einer Partition <= 200

Scroll to Top
Cookie Consent with Real Cookie Banner