Package org.apache.flink.streaming.examples.join

Class WindowJoinSampleData

java.lang.Object

org.apache.flink.streaming.examples.join.WindowJoinSampleData

public class WindowJoinSampleData
extends Object

Sample data for the WindowJoin example.

Constructor Summary

Constructors

Constructor	Description
WindowJoinSampleData()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.connector.datagen.source.DataGeneratorSource<org.apache.flink.api.java.tuple.Tuple2<String,Integer>>	getGradeGeneratorSource(double elementsPerSecond)	Continuously generates (name, grade).
static org.apache.flink.connector.datagen.source.DataGeneratorSource<org.apache.flink.api.java.tuple.Tuple2<String,Integer>>	getSalaryGeneratorSource(double elementsPerSecond)	Continuously generates (name, salary).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WindowJoinSampleData

public WindowJoinSampleData()

Method Detail

getGradeGeneratorSource

public static org.apache.flink.connector.datagen.source.DataGeneratorSource<org.apache.flink.api.java.tuple.Tuple2<String,Integer>> getGradeGeneratorSource(double elementsPerSecond)

Continuously generates (name, grade).

getSalaryGeneratorSource

public static org.apache.flink.connector.datagen.source.DataGeneratorSource<org.apache.flink.api.java.tuple.Tuple2<String,Integer>> getSalaryGeneratorSource(double elementsPerSecond)

Continuously generates (name, salary).