t

com.spotify.scio.testing

BigtableMatchers

trait BigtableMatchers extends SCollectionMatchers

Trait with ScalaTest Matcher s for SCollection s specific to Bigtable output.

Source
BigtableMatchers.scala
Linear Supertypes
SCollectionMatchers, EqInstances, FallbackEqInstances, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BigtableMatchers
  2. SCollectionMatchers
  3. EqInstances
  4. FallbackEqInstances
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. type BTCollection = SCollection[BTRow]
  2. type BTRow = (ByteString, Iterable[Mutation])
  3. sealed trait IterableMatcher[T, B] extends MatcherBuilder[T] with Matcher[T]
    Definition Classes
    SCollectionMatchers
  4. sealed trait MatcherBuilder[T] extends AnyRef
    Definition Classes
    SCollectionMatchers
  5. sealed trait SingleMatcher[T, B] extends MatcherBuilder[T] with Matcher[T]
    Definition Classes
    SCollectionMatchers

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. implicit def arrayEq[T](implicit eqT: Eq[T]): Eq[Array[T]]
    Definition Classes
    EqInstances
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. val beEmpty: IterableMatcher[SCollection[_], Any]

    Assert that the SCollection in question is empty.

    Assert that the SCollection in question is empty.

    Definition Classes
    SCollectionMatchers
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. def containCellMutationCase[V](key: ByteString, mutation: MutationCase): Matcher[BTCollection]

    Check that the BT collection contains a cell with the given row key and enumerated MutationCase, making no assumptions about the contents of the rest of the collection.

  9. def containColumnFamilies(expectedCFs: String*): Matcher[BTCollection]

    Check that the BT collection contains only the given column families, unique, in any order.

  10. 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.

    Assert that the SCollection in question contains the provided elements.

    Definition Classes
    SCollectionMatchers
  11. def containRowKeys(expectedKeys: ByteString*): Matcher[BTCollection]

    Check that the BT collection contains only the given keys, in any order.

  12. def containSetCellValue[V](key: ByteString, cf: String, cq: String, value: V)(implicit ser: (V) => ByteString): Matcher[BTCollection]

    Check that the BT collection contains a cell with the given row key, column family, column qualifier, and deserialized cell value.

    Check that the BT collection contains a cell with the given row key, column family, column qualifier, and deserialized cell value.

    V

    Class of expected value

    key

    Row key the cell should be in

    cf

    Column family the cell should have

    cq

    Column qualifier the cell should have

    value

    Deserialized value of the set cell

    ser

    Serializer to convert value type V to ByteString for BT format

  13. def containSetCellValue[V](key: ByteString, cf: String, value: V)(implicit ser: (V) => ByteString): Matcher[BTCollection]

    Check that the BT collection contains a cell with the given row key, column family, and deserialized cell value.

    Check that the BT collection contains a cell with the given row key, column family, and deserialized cell value. Column qualifier defaults to the same as column family.

  14. 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.

    Assert that the SCollection in question contains a single provided element.

    Definition Classes
    SCollectionMatchers
  15. 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.

    Assert that the SCollection in question contains the provided element without making assumptions about other elements in the collection.

    Definition Classes
    SCollectionMatchers
  16. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. 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.

    Assert that the SCollection in question is equivalent to the provided map.

    Definition Classes
    SCollectionMatchers
  18. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  19. 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.

    Assert that some elements of the SCollection in question satisfy the provided function.

    Definition Classes
    SCollectionMatchers
  20. implicit def fallbackEq[A]: Eq[A]
    Definition Classes
    FallbackEqInstances
  21. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  22. 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.

    Assert that all elements of the SCollection in question satisfy the provided function.

    Definition Classes
    SCollectionMatchers
  23. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  24. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  25. def haveSize(size: Int): IterableMatcher[SCollection[_], Any]

    Assert that the SCollection in question has provided size.

    Assert that the SCollection in question has provided size.

    Definition Classes
    SCollectionMatchers
  26. 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.

    SCollection assertion only applied to the specified window across all panes that were not produced by the arrival of late data.

    Definition Classes
    SCollectionMatchers
  27. def inEarlyGlobalWindowPanes[T, B](matcher: IterableMatcher[T, B]): Matcher[T]

    SCollection assertion only applied to early timing global window.

    SCollection assertion only applied to early timing global window.

    Definition Classes
    SCollectionMatchers
  28. 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.

    SCollection assertion only applied to the specified window, running the checker only on the early pane for each key.

    Definition Classes
    SCollectionMatchers
  29. 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.

    SCollection assertion only applied to the specified window, running the checker only on the final pane for each key.

    Definition Classes
    SCollectionMatchers
  30. 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.

    SCollection assertion only applied to the specified window, running the checker only on the late pane for each key.

    Definition Classes
    SCollectionMatchers
  31. 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.

    SCollection assertion only applied to the specified window, running the checker only on the on-time pane for each key.

    Definition Classes
    SCollectionMatchers
  32. 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.

    Definition Classes
    SCollectionMatchers
  33. def inWindow[T, B](window: BoundedWindow)(matcher: IterableMatcher[T, B]): Matcher[T]

    SCollection assertion only applied to the specified window.

    SCollection assertion only applied to the specified window.

    Definition Classes
    SCollectionMatchers
  34. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  35. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  36. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  37. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  38. 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.

    Assert that the SCollection in question satisfies the provided function.

    Definition Classes
    SCollectionMatchers
  39. 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.

    Assert that the SCollection in question contains a single element which satisfies the provided function.

    Definition Classes
    SCollectionMatchers
  40. implicit def stringBTSerializer(s: String): ByteString

    Provide an implicit BT serializer for common cell value type String.

  41. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  42. def toString(): String
    Definition Classes
    AnyRef → Any
  43. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  44. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  45. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from SCollectionMatchers

Inherited from EqInstances

Inherited from FallbackEqInstances

Inherited from AnyRef

Inherited from Any

Ungrouped