{-# LANGUAGE MultiParamTypeClasses #-}
{-# LANGUAGE OverloadedStrings #-}

module Spark.Core.JoinsSpec where

import Test.Hspec

import Spark.Core.Context
import Spark.Core.Dataset
import Spark.Core.Column
import Spark.Core.ColumnFunctions
import Spark.Core.Row
import Spark.Core.Functions
import Spark.Core.SimpleAddSpec(run)

spec :: Spec
spec = do
  describe "Path test" $ do
    run "test_path1" $ do
      let ds1 = dataset [1] :: Dataset Int
      let x1 = sumCol (asCol ds1) @@ "x1"
      let x2 = ((x1 + 1) @@ "x2") `logicalParents` [untyped ds1]
      res <- exec1Def x2
      res `shouldBe` 2
  -- describe "Join test - join on ints" $ do
  --   run "empty_ints1" $ do
  --     let ds1 = dataset [(1,2)] :: Dataset (Int, Int)
  --     let ds2 = dataset [(1,3)] :: Dataset (Int, Int)
  --     let df1 = asDF ds1
  --     let df2 = asDF ds2
  --     let df = joinInner' (df1/-"_1") (df1/-"_2") (df2/-"_1") (df2/-"_2" @@ "_3")
  --     res <- exec1Def' (collect' (asCol' df))
  --     res `shouldBe` rowArray [rowArray [IntElement 1, IntElement 2, IntElement 3]]