소스 검색

phoenix batchsize

许家凯 5 년 전
부모
커밋
8aeb70be1d
1개의 변경된 파일1개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      src/main/scala/com/winhc/bigdata/spark/config/PhoenixConfig.scala

+ 1 - 0
src/main/scala/com/winhc/bigdata/spark/config/PhoenixConfig.scala

@@ -21,6 +21,7 @@ object PhoenixConfig {
     connProp.put("user", DB_PHOENIX_USER)
     connProp.put("password", DB_PHOENIX_PASS)
     connProp.put("fetchsize", DB_PHOENIX_FETCHSIZE)
+    connProp.put("batchsize", "100000")
     connProp
   }