@@ -45,7 +45,7 @@ public class SolrWriter extends DefaultSolrDocumentReceiver {
45
45
/** Number of document per commit */
46
46
private int batchSize ;
47
47
/** Time range in which a commit will happen. */
48
- private int commitWithMs ;
48
+ private int commitWithinMs ;
49
49
50
50
/** Number of threads to run in parallel */
51
51
int threads ;
@@ -62,7 +62,7 @@ public SolrWriter(String url) {
62
62
this .core = "default" ;
63
63
this .threads = 1 ;
64
64
this .batchSize = 1 ;
65
- this .commitWithMs = 500 ;
65
+ this .commitWithinMs = 500 ;
66
66
this .onStartup = true ;
67
67
}
68
68
@@ -74,8 +74,8 @@ public void setBatchSize(int batchSize) {
74
74
this .batchSize = batchSize ;
75
75
}
76
76
77
- public void setCommitWithMs (int commitWithMs ) {
78
- this .commitWithMs = commitWithMs ;
77
+ public void setCommitWithinMs (int commitWithinMs ) {
78
+ this .commitWithinMs = commitWithinMs ;
79
79
}
80
80
81
81
public void setThreads (int threads ) {
@@ -98,7 +98,7 @@ public void process(SolrInputDocument document) {
98
98
for (int i = 0 ; i < threads ; i ++) {
99
99
SolrCommitProcess process = new SolrCommitProcess (documentChannel .in (), client , core );
100
100
process .setBatchSize (batchSize );
101
- process .setCommitWithinMs (commitWithMs );
101
+ process .setCommitWithinMs (commitWithinMs );
102
102
parallel .addProcess (process );
103
103
}
104
104
0 commit comments