#NEWLINE# def test_pyspark_to_sparksql( ctx , people ) : #NEWLINE# #INDENT# sdf = odo ( data , ctx , dshape = discover ( df ) ) #NEWLINE# assert isinstance ( ctx , SparkDataFrame ) #NEWLINE# assert ( list ( map ( set , odo ( people , list ) ) ) == list ( map ( set , odo ( sdf , list ) ) ) )