WIP: more inprovements 4/n

Author: ritalrw

src/main/java/Loader.java

@@ -321,12 +321,17 @@ public static void main(String[] args) throws IOException {
                 boolean _trackFailures = Boolean.parseBoolean(cmd.getOptionValue("trackFailures", "false"));
                 if (Integer.parseInt(cmd.getOptionValue("retry", "0")) > 0)
                     _trackFailures = true;
-                tm.submit(new WorkLoadGenerate(th_name, dg, clientPool, esClient, cmd.getOptionValue("durability", "NONE"),
+                WorkLoadGenerate wlg = new WorkLoadGenerate(th_name, dg, clientPool, esClient, cmd.getOptionValue("durability", "NONE"),
                         Integer.parseInt(cmd.getOptionValue("maxTTL", "0")),
                         cmd.getOptionValue("maxTTLUnit", "seconds"), _trackFailures,
-                        Integer.parseInt(cmd.getOptionValue("retry", "0")), null));
+                        Integer.parseInt(cmd.getOptionValue("retry", "0")), null);
+                wlg.set_collection_for_load(
+                            cmd.getOptionValue("bucket"),
+                            cmd.getOptionValue("scope", "_default"),
+                            cmd.getOptionValue("collection", "_default"));
                 // Reduced startup delay from 500ms to 50ms for faster ramp-up
                 // With 32 workers: 15.5s → 1.55s startup time
+                tm.submit(wlg);
                 TimeUnit.MILLISECONDS.sleep(50);
             } catch (Exception e) {
                 e.printStackTrace();

src/main/java/couchbase/loadgen/WorkLoadGenerate.java

@@ -225,7 +225,6 @@ public void actual_run() {
             Instant start = Instant.now();
             if(dg.ws.creates > 0) {
                 // Instant st = Instant.now();
-                System.out.println(dg.ws.batchSize);
                 List<Tuple2<String, Object>> docs = dg.nextInsertBatch();
                 // Instant en = Instant.now();
                 // System.out.println(this.taskName + " Time Taken to generate " + docs.size() + "docs: " + Duration.between(st, en).toMillis() + "ms");