THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
MapFunction<Long, String> generator = index -> "Event based onfrom index: " + index; DataGeneratorSource<String> source = new DataGeneratorSource<>(generator, 10, Types.STRING); DataStreamSource<String> watermarked = env.fromSource( source, WatermarkStrategy.forBoundedOutOfOrderness(Duration.ofSeconds(1)), "watermarked"); |
...