Class DataGeneratorPerCheckpoint
- java.lang.Object
-
- org.apache.flink.streaming.examples.datagen.DataGeneratorPerCheckpoint
-
public class DataGeneratorPerCheckpoint extends Object
An example for generating specific data per checkpoint with aDataGeneratorSource.
-
-
Constructor Summary
Constructors Constructor Description DataGeneratorPerCheckpoint()
-