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.
---