Pinned Loading

1. stopstreaming stopstreaming Public

   Stop structured streaming gracefully based on filesystem

   Scala 2 1

2. IoT-device-stream-kafka IoT-device-stream-kafka Public

   Spark and Kafka based producer/consumer

   Scala 2 1

3. Paper-Rock-Scissors Paper-Rock-Scissors Public

   Java

4. yelp-data-challenge yelp-data-challenge Public

   Playing around with with YELP dataset of www.yelp.com

   Scala

5. A generic key based join function fo... A generic key based join function for immutable.Map in Scala. Join is based on intersection of the keys functionality which resembles the "inner join" from the SQL world.

   1

   import scala.collection.immutable

   2

   3

   object implicits {

   4

     type A = Any

   5

     implicit class MapExt[K, B <: A, C <: A](val left: immutable.Map[K, B]) {

6. Drop method for Dataframe that exten... Drop method for Dataframe that extends given API by supporting drop for a list of columns.

   1

   import org.apache.spark.sql.{Column, DataFrame}

   2

   3

   object implicits {

   4

     implicit class DataframeExt(val df: DataFrame) {

   5

       def drop(cols: Seq[Column]) : DataFrame = {