Type Members

1.  class ConfigCreatorWithCollectingListener extends EmptyProcessConfigCreator
2.  class SinkForTypeFunction[T <: AnyRef] extends SinkFunction[T]
3.  class TestResultsHolder[T] extends AnyRef

   This class purpose is for communication between Flink's functions and a unit test code.

   This class purpose is for communication between Flink's functions and a unit test code. Instances of this classes should be kept in the scala object (in some static context) and passed to Flink functions by name to avoid serialization of TestResultsHolder itself (only scala object should be marked as Serializable).

   You should also create dedicated scala objects for each test to make sure that Flink function will "communicate" with the same holder as passed, not some other from other test. // TODO: We could create one scala object and kept data keyed by TestRunId as we do with ResultsCollectingListenerHolder