diff --git a/streamingpro-mlsql/src/main/java/streaming/dsl/LoadAdaptor.scala b/streamingpro-mlsql/src/main/java/streaming/dsl/LoadAdaptor.scala
index df8b3da6e..f3784a290 100644
--- a/streamingpro-mlsql/src/main/java/streaming/dsl/LoadAdaptor.scala
+++ b/streamingpro-mlsql/src/main/java/streaming/dsl/LoadAdaptor.scala
@@ -104,6 +104,10 @@ class BatchLoadAdaptor(scriptSQLExecListener: ScriptSQLExecListener,
         }
         import sparkSession.implicits._
         table = reader.json(sparkSession.createDataset[String](items))
+      case "hive" =>
+        table = reader.table(cleanStr(path))
+      case "text" =>
+        table = reader.text(cleanStr(path).split(","): _*)
       case _ =>
 
         // calculate resource real absolute path