Hi all, I would like to create some data stream queries tests using the TPC-H benchmark. I saw that there are some examples of TPC Q3[1] and Q10[2], however, they are using DataSet. If I consider creating these queries but using DataStream what are the caveats that I have to ensure when implementing the source function? I mean, the frequency of emitting items is certainly the first. I suppose that I would change the frequency of the workload globally for all data sources. Is only it or do you have other things to consider?
[1] https://github.com/apache/flink/blob/master/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery3.java [2] https://github.com/apache/flink/blob/master/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery10.java Thanks, Felipe -- -- Felipe Gutierrez -- skype: felipe.o.gutierrez -- https://felipeogutierrez.blogspot.com
