diff options
| author | wanglihui <[email protected]> | 2020-08-25 14:52:45 +0800 |
|---|---|---|
| committer | wanglihui <[email protected]> | 2020-08-25 14:52:45 +0800 |
| commit | 40e76754d040ff4d1e2aa2532725c791e19a98f3 (patch) | |
| tree | 8289deb3663dce314786209eab583079965fed7f | |
| parent | b7a156b0b84d83836de0bfa44c24e7f7b307dd5e (diff) | |
过滤schema为BASE的日志
| -rw-r--r-- | ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala b/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala index 952c30c..48bbd9a 100644 --- a/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala +++ b/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala @@ -31,7 +31,7 @@ object BaseClickhouseData { } def loadConnectionDataFromCk(): Unit ={ - val where = "common_recv_time >= " + timeLimit._2 + " AND common_recv_time < " + timeLimit._1 + val where = "common_recv_time >= " + timeLimit._2 + " AND common_recv_time < " + timeLimit._1 + " AND common_schema_type != 'BASE'" val sql = s""" |(SELECT |