Testing using embedded Flink (DataStreamAPI)

[mzitnik]

All our unit testing should be implemented using an embedded Flink (Not running in Docker)
Several test cases should be tested.

• RAW Data Insert (CSV, TSV, JSON)
• POJO Classes