hi all i want to do an experiment in the benchmark package and test the injector-rate and received-events, but i get the following confuses:
1. i test two times in the same parameters, but in each time, the number of input events in the injector are different: the first: 3324831 the second: 9808773 and the two experiments have the same parameters: -p=s4.adapter.output.stream=inputStream,s4.benchmark.keysCount=10000,s4.benchmark.testIterations=1000000,s4.benchmark.injector.iterationsBeforePause=1000,s4.benchmark.pauseTimeMs=20,s4.benchmark.injector.parallelism=4 -c=testCluster2 -appName=adapter -zk=node4:2181 i want to expect that very time the injectors have the same rate and finish in definite number of events. can i complete the work and how ? 2. and i do not very clear about the dequeued csv files, dose it stand for the number of the dequeued streams in given time interval. if it is true, how can i get the the number of the events in the streams in very given time interval ?
