in bigtop-bigpetstore/bigpetstore-transaction-queue/src/main/java/org/apache/bigtop/bigpetstore/qstream/LoadGen.java [95:118]
public static void main(String[] args){
try {
LoadGen lg = LoadGenFactory.parseArgs(args);
long start=System.currentTimeMillis();
int runs = 0;
//write everything to /tmp, every 20 seconds.
LinkedBlockingQueue<Transaction> q = lg.startWriteQueue(10000);
while(true){
lg.iterateData(q, System.currentTimeMillis());
runs++;
/**
* if testing , dont run forever. TODO, make runtime configurable.
*/
if(TESTING && runs == 2){
System.out.println("DONE...");
return;
}
}
}
catch(Throwable t){
t.printStackTrace();
System.exit(1);
}
}