def marketBasketAnalysis(session: SparkSession) ={
    import session.sqlContext.implicits._
    val receipts = DataLoader.readCsv()(session)
    //receipts.groupBy("Paragon numer").count()
    receipts
      .groupBy("Paragon numer")
      .count()
      .drop("count")


//receipts.filter(receipts("Paragon numer") === row).select("Produkt ID").collectAsList()

//    val listOfProduct = receipts.filter(receipts("Paragon numer") === 68285).select("Produkt ID").collectAsList()
//    println (listOfProduct) -> flatmap



  }