diff --git a/python/examples/test_dual_write.py b/python/examples/test_dual_write.py index d85e7f9..d6a5632 100644 --- a/python/examples/test_dual_write.py +++ b/python/examples/test_dual_write.py @@ -1,6 +1,7 @@ import os import tempfile +#tag::test[] from sparktestingbase.sqltestcase import SQLTestCase from pyspark.sql.functions import current_timestamp from pyspark.sql.types import Row @@ -21,3 +22,4 @@ def test_actual_dual_write(self): df1 = self.sqlCtx.read.format("parquet").load(p1) df2 = self.sqlCtx.read.format("parquet").load(p2) self.assertDataFrameEqual(df2.select("times"), df1, 0.1) +#end::test[]