Lines Matching refs:ds1
29 val ds1 = Seq("1", "2").toDS().as("a") constant
33 ds1.persist()
35 assert(ds1.storageLevel == StorageLevel.MEMORY_AND_DISK)
38 ds1.unpersist()
39 assert(ds1.storageLevel == StorageLevel.NONE)
41 ds1.persist(StorageLevel.MEMORY_ONLY_2)
42 assert(ds1.storageLevel == StorageLevel.MEMORY_ONLY_2)
44 val joined = ds1.joinWith(ds2, $"a.value" === $"b.value")
65 val ds1 = Seq("1", "2").toDS().as("a") constant
68 ds1.persist()
69 assertCached(ds1)
73 val joined = ds1.joinWith(ds2, $"a.value" === $"b.value")
77 ds1.unpersist()
78 assert(ds1.storageLevel == StorageLevel.NONE, "The Dataset ds1 should not be cached.")