Skip to content

Commit

Permalink
mongo db sync plugin
Browse files Browse the repository at this point in the history
  • Loading branch information
jianying.wcj committed Apr 14, 2015
1 parent 2d51b81 commit 277066f
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -97,6 +97,7 @@ public void startRead(RecordSender recordSender) {

long pageCount = batchSize / pageSize;
long modCount = batchSize % pageSize;
System.out.println("skipCount="+skipCount);
for(int i = 0; i <= pageCount; i++) {
skipCount += i * pageCount;
if (i == pageCount) {
Expand Down

0 comments on commit 277066f

Please sign in to comment.