Oh great! Thanks, Aaron that was quite clear.
I will give it a try!
On Wed, Sep 18, 2019 at 8:29 PM Aaron Levin wrote:
> Hey,
>
> I've used ScalaCheck to test flink applications. Basic idea is:
>
> * use ScalaCheck to generate some kind of collection
> * use `fromCollection` in `StreamExecutionE
Hey,
I've used ScalaCheck to test flink applications. Basic idea is:
* use ScalaCheck to generate some kind of collection
* use `fromCollection` in `StreamExecutionEnvironment` to create a
`DataStream`
* use `DataStreamUtils.collect` as a sink
* plug my flink logic between the collection source a
