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 
      Modifier and Type Method Description
      void matchesRecordsFromSource​(List<List<T>> recordsBySplitsFromSource, org.apache.flink.streaming.api.CheckpointingMode semantic)  
      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

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