Github user emlaver commented on a diff in the pull request:

    https://github.com/apache/bahir/pull/57#discussion_r157552982
  
    --- Diff: 
sql-cloudant/src/main/scala/org/apache/bahir/cloudant/internal/ChangesReceiver.scala
 ---
    @@ -39,56 +37,38 @@ class ChangesReceiver(config: CloudantChangesConfig)
       }
     
       private def receive(): Unit = {
    -    // Get total number of docs in database using _all_docs endpoint
    -    val limit = new JsonStoreDataAccess(config)
    -      .getTotalRows(config.getTotalUrl, queryUsed = false)
    -
    -    // Get continuous _changes url
    +    // Get normal _changes url
         val url = config.getChangesReceiverUrl.toString
         val selector: String = {
           "{\"selector\":" + config.getSelector + "}"
         }
     
    -    var count = 0
    +    // var count = 0
    --- End diff --
    
    Remove in f758996.


---

Reply via email to