You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datafu.apache.org by ey...@apache.org on 2019/05/15 14:13:37 UTC
[datafu] 02/02: rename example_tests
This is an automated email from the ASF dual-hosted git repository.
eyal pushed a commit to branch spark-tmp
in repository https://gitbox.apache.org/repos/asf/datafu.git
commit a410e1c41820e89f92a6a4ea04cae4408a10f787
Author: oraviv <or...@paypal.com>
AuthorDate: Wed May 15 13:46:22 2019 +0300
rename example_tests
---
.../resources/{example_tests => python_tests}/df_utils_tests.py | 0
.../test/resources/{example_tests => python_tests}/pyfromscala.py | 2 +-
.../{example_tests => python_tests}/pyfromscala_with_error.py | 0
.../src/test/scala/datafu/spark/TestScalaPythonBridge.scala | 8 ++++----
datafu-spark/src/test/scala/datafu/spark/TestSparkDFUtils.scala | 2 +-
datafu-spark/src/test/scala/datafu/spark/TestSparkUDAFs.scala | 2 +-
6 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/datafu-spark/src/test/resources/example_tests/df_utils_tests.py b/datafu-spark/src/test/resources/python_tests/df_utils_tests.py
similarity index 100%
rename from datafu-spark/src/test/resources/example_tests/df_utils_tests.py
rename to datafu-spark/src/test/resources/python_tests/df_utils_tests.py
diff --git a/datafu-spark/src/test/resources/example_tests/pyfromscala.py b/datafu-spark/src/test/resources/python_tests/pyfromscala.py
similarity index 98%
rename from datafu-spark/src/test/resources/example_tests/pyfromscala.py
rename to datafu-spark/src/test/resources/python_tests/pyfromscala.py
index 040854b..73939b6 100644
--- a/datafu-spark/src/test/resources/example_tests/pyfromscala.py
+++ b/datafu-spark/src/test/resources/python_tests/pyfromscala.py
@@ -15,7 +15,7 @@
# specific language governing permissions and limitations
# under the License.
-# Some usage exmaples of python-Scala functionality
+# Some usage examples of python-Scala functionality
# print the PYTHONPATH
import sys
diff --git a/datafu-spark/src/test/resources/example_tests/pyfromscala_with_error.py b/datafu-spark/src/test/resources/python_tests/pyfromscala_with_error.py
similarity index 100%
rename from datafu-spark/src/test/resources/example_tests/pyfromscala_with_error.py
rename to datafu-spark/src/test/resources/python_tests/pyfromscala_with_error.py
diff --git a/datafu-spark/src/test/scala/datafu/spark/TestScalaPythonBridge.scala b/datafu-spark/src/test/scala/datafu/spark/TestScalaPythonBridge.scala
index 1408e2c..2781561 100644
--- a/datafu-spark/src/test/scala/datafu/spark/TestScalaPythonBridge.scala
+++ b/datafu-spark/src/test/scala/datafu/spark/TestScalaPythonBridge.scala
@@ -83,7 +83,7 @@ class TestScalaPythonBridge extends FunSuite {
val dfin = spark.sparkContext.parallelize(1 to 10).toDF("num")
dfin.createOrReplaceTempView("dfin")
- runner.runPythonFile("example_tests/pyfromscala.py")
+ runner.runPythonFile("python_tests/pyfromscala.py")
// try to invoke python udf from scala code
assert(
@@ -100,13 +100,13 @@ class TestScalaPythonBridge extends FunSuite {
}
test("pyfromscala_with_error.py") {
- val t = Try(runner.runPythonFile("example_tests/pyfromscala_with_error.py"))
+ val t = Try(runner.runPythonFile("python_tests/pyfromscala_with_error.py"))
assert(t.isFailure)
assert(t.failed.get.isInstanceOf[RuntimeException])
}
test("SparkDFUtilsBridge") {
- runner.runPythonFile("example_tests/df_utils_tests.py")
+ runner.runPythonFile("python_tests/df_utils_tests.py")
assertTable("dedup", "[a,Alice,34], [b,Bob,36], [c,Zoey,36]")
assertTable(
"dedupTopN",
@@ -126,4 +126,4 @@ class TestScalaPythonBridge extends FunSuite {
}
-class ExampleFiles extends PythonResource("example_tests")
+class ExampleFiles extends PythonResource("python_tests")
diff --git a/datafu-spark/src/test/scala/datafu/spark/TestSparkDFUtils.scala b/datafu-spark/src/test/scala/datafu/spark/TestSparkDFUtils.scala
index 8c7453e..045b75b 100644
--- a/datafu-spark/src/test/scala/datafu/spark/TestSparkDFUtils.scala
+++ b/datafu-spark/src/test/scala/datafu/spark/TestSparkDFUtils.scala
@@ -111,7 +111,7 @@ class DataFrameOpsTests extends FunSuite with DataFrameSuiteBase {
assertDataFrameEquals(expectedComplex, actual)
}
- case class Inner(colGrp: String, colOrd: Int)
+ case class Inner(col_grp: String, col_ord: Int)
case class expComplex(
col_grp: String,
diff --git a/datafu-spark/src/test/scala/datafu/spark/TestSparkUDAFs.scala b/datafu-spark/src/test/scala/datafu/spark/TestSparkUDAFs.scala
index 6fe906c..8df9fba 100644
--- a/datafu-spark/src/test/scala/datafu/spark/TestSparkUDAFs.scala
+++ b/datafu-spark/src/test/scala/datafu/spark/TestSparkUDAFs.scala
@@ -213,7 +213,7 @@ class UdafTests extends FunSuite with DataFrameSuiteBase {
)
}
- case class Exp5(colGrp: String, colOrd: Option[Int])
+ case class Exp5(col_grp: String, col_ord: Option[Int])
test("countDistinctUpTo") {
import datafu.spark.SparkUDAFs.CountDistinctUpTo