Package org.apache.flink.connector.testframe.utils

Class UnorderedCollectIteratorAssert<T>

java.lang.Object

org.assertj.core.api.AbstractAssert<UnorderedCollectIteratorAssert<T>,Iterator<T>>

org.apache.flink.connector.testframe.utils.UnorderedCollectIteratorAssert<T>

Type Parameters:

T - The type of records in the test data and collect iterator

All Implemented Interfaces:

org.assertj.core.api.Assert<UnorderedCollectIteratorAssert<T>,Iterator<T>>, org.assertj.core.api.Descriptable<UnorderedCollectIteratorAssert<T>>, org.assertj.core.api.ExtensionPoints<UnorderedCollectIteratorAssert<T>,Iterator<T>>

public class UnorderedCollectIteratorAssert<T>
extends org.assertj.core.api.AbstractAssert<UnorderedCollectIteratorAssert<T>,Iterator<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.

Field Summary

Fields inherited from class org.assertj.core.api.AbstractAssert

actual, info, myself, objects, throwUnsupportedExceptionOnEquals

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	UnorderedCollectIteratorAssert(Iterator<T> collectorIterator)

Method Summary

Modifier and Type	Method	Description
void	matchesRecordsFromSource(List<List<T>> recordsBySplitsFromSource, org.apache.flink.core.execution.CheckpointingMode semantic)
void	matchesRecordsFromSource(List<List<T>> recordsBySplitsFromSource, org.apache.flink.streaming.api.CheckpointingMode semantic)	Deprecated.
UnorderedCollectIteratorAssert<T>	withNumRecordsLimit(int limit)

Methods inherited from class org.assertj.core.api.AbstractAssert

areEqual, asInstanceOf, asList, assertionError, asString, describedAs, descriptionText, doesNotHave, doesNotHaveSameClassAs, doesNotHaveSameHashCodeAs, doesNotHaveToString, equals, extracting, extracting, failure, failureWithActualExpected, failWithActualExpectedAndMessage, failWithMessage, getWritableAssertionInfo, has, hashCode, hasSameClassAs, hasSameHashCodeAs, hasToString, inBinary, inHexadecimal, is, isElementOfCustomAssert, isEqualTo, isExactlyInstanceOf, isIn, isIn, isInstanceOf, isInstanceOfAny, isInstanceOfSatisfying, isNot, isNotEqualTo, isNotExactlyInstanceOf, isNotIn, isNotIn, isNotInstanceOf, isNotInstanceOfAny, isNotNull, isNotOfAnyClassIn, isNotSameAs, isNull, isOfAnyClassIn, isSameAs, matches, matches, newListAssertInstance, overridingErrorMessage, overridingErrorMessage, satisfies, satisfies, satisfies, satisfiesAnyOf, satisfiesAnyOf, satisfiesAnyOfForProxy, satisfiesForProxy, setCustomRepresentation, setDescriptionConsumer, setPrintAssertionsDescription, throwAssertionError, usingComparator, usingComparator, usingDefaultComparator, usingRecursiveComparison, usingRecursiveComparison, withFailMessage, withFailMessage, withRepresentation, withThreadDumpOnError

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.assertj.core.api.Descriptable

as, as, as, describedAs

Constructor Detail

UnorderedCollectIteratorAssert

protected UnorderedCollectIteratorAssert(Iterator<T> collectorIterator)

Method Detail

withNumRecordsLimit

public UnorderedCollectIteratorAssert<T> withNumRecordsLimit(int limit)

matchesRecordsFromSource

@Deprecated
public void matchesRecordsFromSource(List<List<T>> recordsBySplitsFromSource,
                                     org.apache.flink.streaming.api.CheckpointingMode semantic)

Deprecated.

This method is required for downstream projects e.g. Flink connectors extending this test for the case when there should be supported Flink versions below 1.20. Could be removed together with dropping support for Flink 1.19.

matchesRecordsFromSource

public void matchesRecordsFromSource(List<List<T>> recordsBySplitsFromSource,
                                     org.apache.flink.core.execution.CheckpointingMode semantic)