Hi, I want to emit a bounded sequence of numbers from 0 to n but downstream to receive this sequence at a given rate.
This is needed so that we can rate limit the HTTP request downstream. Say if we generate sequence from 1 - 100 then downstream would make 100 such requests almost at the same time. So to add gaps I am trying something like this. Would a code like this work ? pipeline .apply(GenerateSequence.from(0).to(100).withRate(1, Duration.standardSeconds (5))) .apply(ParDo.of(new BatchDataLoad())) .apply(KinesisIO.write() .withStreamName(streamName) // other configs ); Somehow this does not seem to be generating numbers at that rate which is 1 per 5 seconds but all at one time. Also looks like it may be creating an unbounded collection and looks like kinesis is not writing anything to the stream. If not then is there a way to achieve this? Thanks Sachin
