Test application SmoothingIT (implementation based on TestNG)
- Test send windowed data
- send
com.ness.flink.example.pipeline.domain.InterestRate - send
com.ness.flink.example.pipeline.domain.OptionPrice
- send
- Test checks produced
com.ness.flink.example.pipeline.domain.SmoothingRequestby Flink application with expected results (Test checks based on eventual consistency).