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

Class CollectIteratorAssert<T>

  • Type Parameters:
    T - The type of records in the test data and collect iterator
    All Implemented Interfaces:
    org.assertj.core.api.Assert<CollectIteratorAssert<T>,​Iterator<T>>, org.assertj.core.api.Descriptable<CollectIteratorAssert<T>>, org.assertj.core.api.ExtensionPoints<CollectIteratorAssert<T>,​Iterator<T>>
    public class CollectIteratorAssert<T>
extends org.assertj.core.api.AbstractAssert<CollectIteratorAssert<T>,​Iterator<T>>
    This assertion used to compare records in the collect iterator to the target test data with different semantic(AT_LEAST_ONCE, EXACTLY_ONCE).

    • Field Summary

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

        actual, info, myself, objects, throwUnsupportedExceptionOnEquals

    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      void matchesRecordsFromSource​(List<List<T>> recordsBySplitsFromSource, CheckpointingMode semantic)  
      void matchesRecordsFromSource​(List<List<T>> recordsBySplitsFromSource, CheckpointingMode semantic)
      Deprecated.
      CollectIteratorAssert<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 interface org.assertj.core.api.Descriptable

        as, as, as, describedAs

    • Constructor Detail

      • CollectIteratorAssert

        protected CollectIteratorAssert​(Iterator<T> collectorIterator)

    • Method Detail

      • matchesRecordsFromSource

        @Deprecated
public void matchesRecordsFromSource​(List<List<T>> recordsBySplitsFromSource,
                                     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,
                                     CheckpointingMode semantic)