Package org.apache.flink.connector.testframe.utils
-
Class Summary Class Description CollectIteratorAssert<T> This assertion used to compare records in the collect iterator to the target test data with different semantic(AT_LEAST_ONCE, EXACTLY_ONCE).CollectIteratorAssertions Entry point for assertion methods forCollectIteratorAssert.ConnectorTestConstants The default configuration values used in connector tests.MetricQuerier The querier used to get job metrics by rest API.UnorderedCollectIteratorAssert<T> This assertion used to compare records in the collect iterator to the target test data with different semantics (AT_LEAST_ONCE, EXACTLY_ONCE) for unordered messages.