Class WindowJoinSampleData
- java.lang.Object
-
- org.apache.flink.streaming.examples.join.WindowJoinSampleData
-
public class WindowJoinSampleData extends Object
Sample data for theWindowJoin
example.
-
-
Constructor Summary
Constructors Constructor Description WindowJoinSampleData()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static DataGeneratorSource<Tuple2<String,Integer>>
getGradeGeneratorSource(double elementsPerSecond)
Continuously generates (name, grade).static DataGeneratorSource<Tuple2<String,Integer>>
getSalaryGeneratorSource(double elementsPerSecond)
Continuously generates (name, salary).
-
-
-
Method Detail
-
getGradeGeneratorSource
public static DataGeneratorSource<Tuple2<String,Integer>> getGradeGeneratorSource(double elementsPerSecond)
Continuously generates (name, grade).
-
getSalaryGeneratorSource
public static DataGeneratorSource<Tuple2<String,Integer>> getSalaryGeneratorSource(double elementsPerSecond)
Continuously generates (name, salary).
-
-