@@ -76,47 +76,47 @@ public class TaskRequest {
7676 @ JsonProperty ("create_percent" )
7777 private int createPercent ;
7878 @ JsonProperty ("create_start" )
79- private int createStartIndex ;
79+ private long createStartIndex ;
8080 @ JsonProperty ("create_end" )
81- private int createEndIndex ;
81+ private long createEndIndex ;
8282 // Delete params
8383 @ JsonProperty ("delete_percent" )
8484 private int deletePercent ;
8585 @ JsonProperty ("delete_start" )
86- private int deleteStartIndex ;
86+ private long deleteStartIndex ;
8787 @ JsonProperty ("delete_end" )
88- private int deleteEndIndex ;
88+ private long deleteEndIndex ;
8989 // Update params
9090 @ JsonProperty ("update_percent" )
9191 private int updatePercent ;
9292 @ JsonProperty ("update_start" )
93- private int updateStartIndex ;
93+ private long updateStartIndex ;
9494 @ JsonProperty ("update_end" )
95- private int updateEndIndex ;
95+ private long updateEndIndex ;
9696 // Read params
9797 @ JsonProperty ("read_percent" )
9898 private int readPercent ;
9999 @ JsonProperty ("read_start" )
100- private int readStartIndex ;
100+ private long readStartIndex ;
101101 @ JsonProperty ("read_end" )
102- private int readEndIndex ;
102+ private long readEndIndex ;
103103 // Touch params
104104 @ JsonProperty ("touch_start" )
105- private int touchStartIndex ;
105+ private long touchStartIndex ;
106106 @ JsonProperty ("touch_end" )
107- private int touchEndIndex ;
107+ private long touchEndIndex ;
108108 // Replace params
109109 @ JsonProperty ("replace_start" )
110- private int replaceStartIndex ;
110+ private long replaceStartIndex ;
111111 @ JsonProperty ("replace_end" )
112- private int replaceEndIndex ;
112+ private long replaceEndIndex ;
113113 // Expiry params
114114 @ JsonProperty ("expiry_percent" )
115115 private int expiryPercent ;
116116 @ JsonProperty ("expiry_start" )
117- private int expiryStartIndex ;
117+ private long expiryStartIndex ;
118118 @ JsonProperty ("expiry_end" )
119- private int expiryEndIndex ;
119+ private long expiryEndIndex ;
120120 // Subdoc params
121121 @ JsonProperty ("subdoc_percent" )
122122 private int subdocPercent ;
@@ -128,24 +128,24 @@ public class TaskRequest {
128128 private boolean isSubdocSysXattr ;
129129 // Subdoc insert params
130130 @ JsonProperty ("sd_insert_start" )
131- private int sdInsertStartIndex ;
131+ private long sdInsertStartIndex ;
132132 @ JsonProperty ("sd_insert_end" )
133- private int sdInsertEndIndex ;
133+ private long sdInsertEndIndex ;
134134 // Subdoc upsert params
135135 @ JsonProperty ("sd_upsert_start" )
136- private int sdUpsertStartIndex ;
136+ private long sdUpsertStartIndex ;
137137 @ JsonProperty ("sd_upsert_end" )
138- private int sdUpsertEndIndex ;
138+ private long sdUpsertEndIndex ;
139139 // Subdoc remove params
140140 @ JsonProperty ("sd_remove_start" )
141- private int sdRemoveStartIndex ;
141+ private long sdRemoveStartIndex ;
142142 @ JsonProperty ("sd_remove_end" )
143- private int sdRemoveEndIndex ;
143+ private long sdRemoveEndIndex ;
144144 // Subdoc lookup params
145145 @ JsonProperty ("sd_read_start" )
146- private int sdReadStartIndex ;
146+ private long sdReadStartIndex ;
147147 @ JsonProperty ("sd_read_end" )
148- private int sdReadEndIndex ;
148+ private long sdReadEndIndex ;
149149 // Document related params
150150 @ JsonProperty ("key_prefix" )
151151 private String keyPrefix ;
@@ -792,7 +792,7 @@ public ResponseEntity<Map<String, Object>> loadSIFTDataset() throws IOException
792792 int [] steps = new int [] { 0 , 1000000 , 2000000 , 5000000 , 10000000 , 20000000 , 50000000 , 100000000 , 200000000 ,
793793 500000000 , 1000000000 };
794794 int poolSize = this .processConcurrency ;
795- int start_offset = 0 , end_offset = 0 ;
795+ long start_offset = 0 , end_offset = 0 ;
796796 if (this .createPercent > 0 ) {
797797 start_offset = this .createStartIndex ;
798798 end_offset = this .createEndIndex ;
@@ -806,9 +806,9 @@ public ResponseEntity<Map<String, Object>> loadSIFTDataset() throws IOException
806806 while (!(steps [k ] <= start_offset && start_offset < steps [k + 1 ]))
807807 k += 1 ;
808808 while (steps [k ] < end_offset ) {
809- int start = Math .max (start_offset , steps [k ]);
810- int end = Math .min (end_offset , steps [k + 1 ]);
811- int step = (end - start ) / poolSize ;
809+ long start = Math .max (start_offset , steps [k ]);
810+ long end = Math .min (end_offset , steps [k + 1 ]);
811+ long step = (end - start ) / poolSize ;
812812 for (int i = 0 ; i < poolSize ; i ++) {
813813 WorkLoadSettings ws = new WorkLoadSettings (this .keyPrefix ,
814814 this .keySize , this .docSize ,
0 commit comments