trait SCollectionMatchers extends EqInstances
- Alphabetic
- By Inheritance
- SCollectionMatchers
- EqInstances
- FallbackEqInstances
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- sealed trait IterableMatcher[T, B] extends MatcherBuilder[T] with Matcher[T]
- sealed trait MatcherBuilder[T] extends AnyRef
- sealed trait SingleMatcher[T, B] extends MatcherBuilder[T] with Matcher[T]
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- implicit def arrayEq[T](implicit eqT: Eq[T]): Eq[Array[T]]
- Definition Classes
- EqInstances
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val beEmpty: IterableMatcher[SCollection[_], Any]
Assert that the SCollection in question is empty.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def containInAnyOrder[T](value: Iterable[T])(implicit arg0: Coder[T], arg1: Eq[T]): IterableMatcher[SCollection[T], T]
Assert that the SCollection in question contains the provided elements.
- def containSingleValue[T](value: T)(implicit arg0: Coder[T], arg1: Eq[T]): SingleMatcher[SCollection[T], T]
Assert that the SCollection in question contains a single provided element.
- def containValue[T](value: T)(implicit arg0: Coder[T], arg1: Eq[T]): IterableMatcher[SCollection[T], T]
Assert that the SCollection in question contains the provided element without making assumptions about other elements in the collection.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equalMapOf[K, V](value: Map[K, V])(implicit arg0: Coder[K], arg1: Coder[V]): SingleMatcher[SCollection[(K, V)], Map[K, V]]
Assert that the SCollection in question is equivalent to the provided map.
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def exist[T](predicate: (T) => Boolean)(implicit arg0: Coder[T], arg1: Eq[T]): IterableMatcher[SCollection[T], T]
Assert that some elements of the SCollection in question satisfy the provided function.
- implicit def fallbackEq[A]: Eq[A]
- Definition Classes
- FallbackEqInstances
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def forAll[T](predicate: (T) => Boolean)(implicit arg0: Coder[T], arg1: Eq[T]): IterableMatcher[SCollection[T], T]
Assert that all elements of the SCollection in question satisfy the provided function.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def haveSize(size: Int): IterableMatcher[SCollection[_], Any]
Assert that the SCollection in question has provided size.
- def inCombinedNonLatePanes[T, B](window: BoundedWindow)(matcher: IterableMatcher[T, B]): Matcher[T]
SCollection assertion only applied to the specified window across all panes that were not produced by the arrival of late data.
- def inEarlyGlobalWindowPanes[T, B](matcher: IterableMatcher[T, B]): Matcher[T]
SCollection assertion only applied to early timing global window.
- def inEarlyPane[T](window: BoundedWindow)(matcher: MatcherBuilder[T]): Matcher[T]
SCollection assertion only applied to the specified window, running the checker only on the early pane for each key.
- def inFinalPane[T, B](window: BoundedWindow)(matcher: MatcherBuilder[T]): Matcher[T]
SCollection assertion only applied to the specified window, running the checker only on the final pane for each key.
- def inLatePane[T, B](window: BoundedWindow)(matcher: MatcherBuilder[T]): Matcher[T]
SCollection assertion only applied to the specified window, running the checker only on the late pane for each key.
- def inOnTimePane[T](window: BoundedWindow)(matcher: MatcherBuilder[T]): Matcher[T]
SCollection assertion only applied to the specified window, running the checker only on the on-time pane for each key.
- def inOnlyPane[T, B](window: BoundedWindow)(matcher: SingleMatcher[T, B]): Matcher[T]
SCollection assertion only applied to the specified window.
SCollection assertion only applied to the specified window. The assertion expect outputs to be produced to the provided window exactly once.
- def inWindow[T, B](window: BoundedWindow)(matcher: IterableMatcher[T, B]): Matcher[T]
SCollection assertion only applied to the specified window.
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def satisfy[T](predicate: (Iterable[T]) => Boolean)(implicit arg0: Coder[T], arg1: Eq[T]): IterableMatcher[SCollection[T], T]
Assert that the SCollection in question satisfies the provided function.
- def satisfySingleValue[T](predicate: (T) => Boolean)(implicit arg0: Coder[T], arg1: Eq[T]): SingleMatcher[SCollection[T], T]
Assert that the SCollection in question contains a single element which satisfies the provided function.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()