File tree Expand file tree Collapse file tree 2 files changed +9
-0
lines changed
mllib/src/main/scala/org/apache/spark/mllib/linalg Expand file tree Collapse file tree 2 files changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -26,6 +26,7 @@ import scala.collection.JavaConverters._
2626import breeze .linalg .{DenseVector => BDV , SparseVector => BSV , Vector => BV }
2727
2828import org .apache .spark .SparkException
29+ import org .apache .spark .annotation .DeveloperApi
2930import org .apache .spark .mllib .util .NumericParser
3031import org .apache .spark .sql .Row
3132import org .apache .spark .sql .catalyst .expressions .GenericMutableRow
@@ -110,9 +111,12 @@ sealed trait Vector extends Serializable {
110111}
111112
112113/**
114+ * :: DeveloperApi ::
115+ *
113116 * User-defined type for [[Vector ]] which allows easy interaction with SQL
114117 * via [[org.apache.spark.sql.DataFrame ]].
115118 */
119+ @ DeveloperApi
116120class VectorUDT extends UserDefinedType [Vector ] {
117121
118122 override def sqlType : StructType = {
Original file line number Diff line number Diff line change @@ -143,6 +143,11 @@ object MimaExcludes {
143143 " org.apache.spark.graphx.Graph.getCheckpointFiles" ),
144144 ProblemFilters .exclude[MissingMethodProblem ](
145145 " org.apache.spark.graphx.Graph.isCheckpointed" )
146+ ) ++ Seq (
147+ // SPARK-4789 Standardize ML Prediction APIs
148+ ProblemFilters .exclude[MissingTypesProblem ](" org.apache.spark.mllib.linalg.VectorUDT" ),
149+ ProblemFilters .exclude[IncompatibleResultTypeProblem ](" org.apache.spark.mllib.linalg.VectorUDT.serialize" ),
150+ ProblemFilters .exclude[IncompatibleResultTypeProblem ](" org.apache.spark.mllib.linalg.VectorUDT.sqlType" )
146151 )
147152
148153 case v if v.startsWith(" 1.2" ) =>
You can’t perform that action at this time.
0 commit comments