aboutsummaryrefslogtreecommitdiff
path: root/mllib
diff options
context:
space:
mode:
authorXiangrui Meng <meng@databricks.com>2016-06-20 21:51:02 -0700
committerReynold Xin <rxin@databricks.com>2016-06-20 21:51:02 -0700
commit18a8a9b1f4114211cd108efda5672f2bd2c6e5cd (patch)
treea8ad1b08b6d37604d03258578b7c60a4191ccbef /mllib
parentd9a3a2a0bec504d17d3b94104d449ee3bd850120 (diff)
downloadspark-18a8a9b1f4114211cd108efda5672f2bd2c6e5cd.tar.gz
spark-18a8a9b1f4114211cd108efda5672f2bd2c6e5cd.tar.bz2
spark-18a8a9b1f4114211cd108efda5672f2bd2c6e5cd.zip
[SPARK-16074][MLLIB] expose VectorUDT/MatrixUDT in a public API
## What changes were proposed in this pull request? Both VectorUDT and MatrixUDT are private APIs, because UserDefinedType itself is private in Spark. However, in order to let developers implement their own transformers and estimators, we should expose both types in a public API to simply the implementation of transformSchema, transform, etc. Otherwise, they need to get the data types using reflection. ## How was this patch tested? Unit tests in Scala and Java. Author: Xiangrui Meng <meng@databricks.com> Closes #13789 from mengxr/SPARK-16074.
Diffstat (limited to 'mllib')
-rw-r--r--mllib/src/main/scala/org/apache/spark/ml/linalg/dataTypes.scala35
-rw-r--r--mllib/src/test/java/org/apache/spark/ml/linalg/JavaSQLDataTypesSuite.java31
-rw-r--r--mllib/src/test/scala/org/apache/spark/ml/linalg/SQLDataTypesSuite.scala27
3 files changed, 93 insertions, 0 deletions
diff --git a/mllib/src/main/scala/org/apache/spark/ml/linalg/dataTypes.scala b/mllib/src/main/scala/org/apache/spark/ml/linalg/dataTypes.scala
new file mode 100644
index 0000000000..52a6fd25e2
--- /dev/null
+++ b/mllib/src/main/scala/org/apache/spark/ml/linalg/dataTypes.scala
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.spark.ml.linalg
+
+import org.apache.spark.annotation.DeveloperApi
+import org.apache.spark.sql.types.DataType
+
+/**
+ * :: DeveloperApi ::
+ * SQL data types for vectors and matrices.
+ */
+@DeveloperApi
+object sqlDataTypes {
+
+ /** Data type for [[Vector]]. */
+ val VectorType: DataType = new VectorUDT
+
+ /** Data type for [[Matrix]]. */
+ val MatrixType: DataType = new MatrixUDT
+}
diff --git a/mllib/src/test/java/org/apache/spark/ml/linalg/JavaSQLDataTypesSuite.java b/mllib/src/test/java/org/apache/spark/ml/linalg/JavaSQLDataTypesSuite.java
new file mode 100644
index 0000000000..b09e13112f
--- /dev/null
+++ b/mllib/src/test/java/org/apache/spark/ml/linalg/JavaSQLDataTypesSuite.java
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.spark.ml.linalg;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+import static org.apache.spark.ml.linalg.sqlDataTypes.*;
+
+public class JavaSQLDataTypesSuite {
+ @Test
+ public void testSQLDataTypes() {
+ Assert.assertEquals(new VectorUDT(), VectorType());
+ Assert.assertEquals(new MatrixUDT(), MatrixType());
+ }
+}
diff --git a/mllib/src/test/scala/org/apache/spark/ml/linalg/SQLDataTypesSuite.scala b/mllib/src/test/scala/org/apache/spark/ml/linalg/SQLDataTypesSuite.scala
new file mode 100644
index 0000000000..13bf3d3015
--- /dev/null
+++ b/mllib/src/test/scala/org/apache/spark/ml/linalg/SQLDataTypesSuite.scala
@@ -0,0 +1,27 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.spark.ml.linalg
+
+import org.apache.spark.SparkFunSuite
+
+class SQLDataTypesSuite extends SparkFunSuite {
+ test("sqlDataTypes") {
+ assert(sqlDataTypes.VectorType === new VectorUDT)
+ assert(sqlDataTypes.MatrixType === new MatrixUDT)
+ }
+}