Package | Description |
---|---|
org.apache.flink.connector.testframe.utils |
Class and Description |
---|
CollectIteratorAssert
This assertion used to compare records in the collect iterator to the target test data with
different semantic(AT_LEAST_ONCE, EXACTLY_ONCE).
|
UnorderedCollectIteratorAssert
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.