[update] add stream operation type

dongbin86 · May 29, 2019 · 2004812 · 2004812
1 parent bc60c4d
commit 2004812
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/streamingpro-api/src/main/java/streaming/dsl/auth/Protocal.scala b/streamingpro-api/src/main/java/streaming/dsl/auth/Protocal.scala
@@ -92,15 +92,15 @@ object TableType {
   val HIVE = TableTypeMeta("hive", Set("hive"))
   val CUSTOME = TableTypeMeta("custom", Set("custom"))
   val HBASE = TableTypeMeta("hbase", Set("hbase"))
-  val HDFS = TableTypeMeta("hdfs", Set("parquet", "json", "csv", "image", "text", "xml", "excel", "libsvm", "delta", "rate"))
+  val HDFS = TableTypeMeta("hdfs", Set("parquet", "json", "csv", "image", "text", "xml", "excel", "libsvm", "delta", "rate", "streamParquet"))
   val HTTP = TableTypeMeta("http", Set("http"))
   val JDBC = TableTypeMeta("jdbc", Set("jdbc", "streamJDBC"))
   val ES = TableTypeMeta("es", Set("es"))
   val REDIS = TableTypeMeta("redis", Set("redis"))
   val KAFKA = TableTypeMeta("kafka", Set("kafka", "kafka8", "kafka9"))
   val SOCKET = TableTypeMeta("socket", Set("socket"))
   val MONGO = TableTypeMeta("mongo", Set("mongo"))
-  val SOLR = TableTypeMeta("solr", Set("solr"))
+  val SOLR = TableTypeMeta("solr", Set("solr", "streamSolr"))
   val TEMP = TableTypeMeta("temp", Set("temp", "jsonStr", "script", "csvStr", "mockStream", "console"))
   val API = TableTypeMeta("api", Set("mlsqlAPI", "mlsqlConf"))
   val WEB = TableTypeMeta("web", Set("crawlersql"))