Skip to content Skip to sidebar Skip to footer
Showing posts with the label Scala

Apache Spark Broadcast Variables Are Type Broadcast? Not A Rdd?

Just trying to clarify something, some low-hanging fruit, a question generated by watching a user i… Read more Apache Spark Broadcast Variables Are Type Broadcast? Not A Rdd?

Bootstrapping A Web Server In Scala

The following is possible using Python: $ apt-get install python $ easy_install Flask $ cat > he… Read more Bootstrapping A Web Server In Scala

How To Split A Text File Into Multiple Columns With Spark

I'm having difficulty on splitting a text data file with delimiter '|' into data frame … Read more How To Split A Text File Into Multiple Columns With Spark

How To Use Scala Udf In Pyspark?

I want to be able to use a Scala function as a UDF in PySpark package com.test object ScalaPySpark… Read more How To Use Scala Udf In Pyspark?

How Can A Reduce A Key Value Pair To Key And List Of Values?

Let us Assume, I have a key value pair in Spark, such as the following. [ (Key1, Value1), (Key1, Va… Read more How Can A Reduce A Key Value Pair To Key And List Of Values?