Skip to content

Commit f9672bf

Browse files
committed
fixed style checks and tests
1 parent 1c0ddb9 commit f9672bf

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

python/pyspark/ml/tests.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1535,14 +1535,13 @@ def test_java_array_of_primitive(self):
15351535
self.assertEqual(_java2py(self.sc, java_array), float_list)
15361536

15371537
def test_java_array_of_class(self):
1538-
#vec_list = [DenseVector([0.0, 1.0]), DenseVector([1.0, 0.0])]
1538+
# test creating a JavaArray of Java DenseVectors
15391539
v1 = DenseVector([0.0, 1.0])
15401540
v2 = DenseVector([1.0, 0.0])
15411541
vec_java_list = [_py2java(self.sc, v1), _py2java(self.sc, v2)]
1542-
java_array = JavaWrapper._new_java_array(vec_java_list, self.sc._gateway.jvm.org.apache.spark.ml.linalg.DenseVector)
1543-
self.assertEqual(_java2py(self.sc, java_array), vec_java_list)
1544-
#rdd_list = [_py2java()]
1545-
#java_array = JavaWrapper._new_java_array(rdd_list, self.sc._gateway.jvm.org.apache.spark.rdd.EmptyRDD)
1542+
java_class = self.sc._gateway.jvm.org.apache.spark.ml.linalg.DenseVector
1543+
java_array = JavaWrapper._new_java_array(vec_java_list, java_class)
1544+
self.assertEqual(_java2py(self.sc, java_array), [v1, v2])
15461545

15471546

15481547
if __name__ == "__main__":

0 commit comments

Comments
 (0)