Dynamic number of smaller visitors, with larger resize window
@@ -195,10 +195,10 @@ public class Reindexer {
VisitorParameters parameters = new VisitorParameters(type.getName());
parameters.setThrottlePolicy(new DynamicThrottlePolicy().setWindowSizeIncrement(1)
.setWindowSizeDecrementFactor(5)
- .setWeight(0.1)
- .setMinWindowSize(4)
- .setMaxWindowSize(4));
+ .setResizeRate(10)
+ .setMinWindowSize(1));
parameters.setRemoteDataHandler(cluster.name());
+ parameters.setMaxPending(8);
parameters.setResumeToken(progress);
parameters.setFieldSet(type.getName() + ":[document]");
parameters.setPriority(DocumentProtocol.Priority.NORMAL_3);
