Merge branch 'master' into MPIP-1031

dongbin86 · Apr 18, 2019 · c9f8a9a · c9f8a9a
2 parents 17e43e5 + 8d84636
commit c9f8a9a
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 1 deletion.
diff --git a/streamingpro-api/src/main/java/streaming/dsl/auth/Protocal.scala b/streamingpro-api/src/main/java/streaming/dsl/auth/Protocal.scala
@@ -84,7 +84,7 @@ object OperateType extends Enumeration {
 object TableType {
   val HIVE = TableTypeMeta("hive", Set("hive"))
   val HBASE = TableTypeMeta("hbase", Set("hbase"))
-  val HDFS = TableTypeMeta("hdfs", Set("parquet", "json", "csv", "image", "text", "xml", "excel"))
+  val HDFS = TableTypeMeta("hdfs", Set("parquet", "json", "csv", "image", "text", "xml", "excel", "libsvm"))
   val HTTP = TableTypeMeta("http", Set("http"))
   val JDBC = TableTypeMeta("jdbc", Set("jdbc", "streamJDBC"))
   val ES = TableTypeMeta("es", Set("es"))

diff --git a/streamingpro-mlsql/src/main/java/streaming/core/datasource/impl/MLSQLLibSVM.scala b/streamingpro-mlsql/src/main/java/streaming/core/datasource/impl/MLSQLLibSVM.scala
@@ -0,0 +1,16 @@
+package streaming.core.datasource.impl
+
+import streaming.core.datasource.MLSQLBaseFileSource
+import streaming.dsl.mmlib.algs.param.{BaseParams, WowParams}
+
+/**
+  * 2019-04-18 WilliamZhu([email protected])
+  */
+class MLSQLLibSVM(override val uid: String) extends MLSQLBaseFileSource with WowParams {
+  def this() = this(BaseParams.randomUID())
+
+  override def fullFormat: String = "libsvm"
+
+  override def shortFormat: String = "libsvm"
+
+}