com.holdenkarau.spark.testing

StreamingSuiteBase

Related Doc: package testing

trait StreamingSuiteBase extends FunSuite with BeforeAndAfterAll with Logging with StreamingSuiteCommon with SharedSparkContext

This is the base trait for Spark Streaming testsuites. This provides basic functionality to run user-defined set of input on user-defined stream operations, and verify the output.

Linear Supertypes
SharedSparkContext, StreamingSuiteCommon, SparkContextProvider, Logging, BeforeAndAfterAll, SuiteMixin, FunSuite, FunSuiteLike, Documenting, Alerting, Notifying, Informing, TestRegistration, Suite, Serializable, AbstractSuite, Assertions, TripleEquals, TripleEqualsSupport, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. StreamingSuiteBase
  2. SharedSparkContext
  3. StreamingSuiteCommon
  4. SparkContextProvider
  5. Logging
  6. BeforeAndAfterAll
  7. SuiteMixin
  8. FunSuite
  9. FunSuiteLike
  10. Documenting
  11. Alerting
  12. Notifying
  13. Informing
  14. TestRegistration
  15. Suite
  16. Serializable
  17. AbstractSuite
  18. Assertions
  19. TripleEquals
  20. TripleEqualsSupport
  21. AnyRef
  22. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. class AssertionsHelper extends AnyRef

    Definition Classes
    Assertions
  2. class CheckingEqualizer[L] extends AnyRef

    Definition Classes
    TripleEqualsSupport
  3. class Equalizer[L] extends AnyRef

    Definition Classes
    TripleEqualsSupport
  4. class LegacyCheckingEqualizer[L] extends AnyRef

    Definition Classes
    TripleEqualsSupport
  5. class LegacyEqualizer[L] extends AnyRef

    Definition Classes
    TripleEqualsSupport
  6. trait NoArgTest extends () ⇒ Outcome with TestData

    Attributes
    protected
    Definition Classes
    Suite

Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  2. def !==[T](right: Spread[T]): TripleEqualsInvocationOnSpread[T]

    Definition Classes
    TripleEqualsSupport
  3. def !==(right: Null): TripleEqualsInvocation[Null]

    Definition Classes
    TripleEqualsSupport
  4. def !==[T](right: T): TripleEqualsInvocation[T]

    Definition Classes
    TripleEqualsSupport
  5. final def ##(): Int

    Definition Classes
    AnyRef → Any
  6. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  7. def ===[T](right: Spread[T]): TripleEqualsInvocationOnSpread[T]

    Definition Classes
    TripleEqualsSupport
  8. def ===(right: Null): TripleEqualsInvocation[Null]

    Definition Classes
    TripleEqualsSupport
  9. def ===[T](right: T): TripleEqualsInvocation[T]

    Definition Classes
    TripleEqualsSupport
  10. def actuallyWait: Boolean

    Definition Classes
    StreamingSuiteCommon
  11. def afterAll(): Unit

    Definition Classes
    StreamingSuiteBase → SharedSparkContext → BeforeAndAfterAll
  12. def alert: Alerter

    Attributes
    protected
    Definition Classes
    FunSuiteLike → Alerting
  13. val appID: String

    Definition Classes
    SharedSparkContext
  14. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  15. macro def assert(condition: Boolean, clue: Any): Unit

    Definition Classes
    Assertions
  16. macro def assert(condition: Boolean): Unit

    Definition Classes
    Assertions
  17. macro def assertCompiles(code: String): Unit

    Definition Classes
    Assertions
  18. macro def assertDoesNotCompile(code: String): Unit

    Definition Classes
    Assertions
  19. def assertResult(expected: Any)(actual: Any): Unit

    Definition Classes
    Assertions
  20. def assertResult(expected: Any, clue: Any)(actual: Any): Unit

    Definition Classes
    Assertions
  21. macro def assertTypeError(code: String): Unit

    Definition Classes
    Assertions
  22. val assertionsHelper: AssertionsHelper

    Definition Classes
    Assertions
  23. macro def assume(condition: Boolean, clue: Any): Unit

    Definition Classes
    Assertions
  24. macro def assume(condition: Boolean): Unit

    Definition Classes
    Assertions
  25. def batchDuration: Duration

    Definition Classes
    StreamingSuiteCommon
  26. def beforeAll(): Unit

    Definition Classes
    StreamingSuiteBase → SharedSparkContext → BeforeAndAfterAll
  27. def cancel(cause: Throwable): Nothing

    Definition Classes
    Assertions
  28. def cancel(message: String, cause: Throwable): Nothing

    Definition Classes
    Assertions
  29. def cancel(message: String): Nothing

    Definition Classes
    Assertions
  30. def cancel(): Nothing

    Definition Classes
    Assertions
  31. lazy val checkpointDir: String

    Definition Classes
    StreamingSuiteCommon
  32. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. val conf: SparkConf

  34. def conversionCheckedConstraint[A, B](implicit equivalenceOfA: Equivalence[A], cnv: (B) ⇒ A): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  35. def convertEquivalenceToAToBConstraint[A, B](equivalenceOfB: Equivalence[B])(implicit ev: <:<[A, B]): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  36. def convertEquivalenceToAToBConversionConstraint[A, B](equivalenceOfB: Equivalence[B])(implicit ev: (A) ⇒ B): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  37. def convertEquivalenceToBToAConstraint[A, B](equivalenceOfA: Equivalence[A])(implicit ev: <:<[B, A]): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  38. def convertEquivalenceToBToAConversionConstraint[A, B](equivalenceOfA: Equivalence[A])(implicit ev: (B) ⇒ A): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  39. def convertToCheckingEqualizer[T](left: T): CheckingEqualizer[T]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  40. implicit def convertToEqualizer[T](left: T): Equalizer[T]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  41. def convertToLegacyCheckingEqualizer[T](left: T): LegacyCheckingEqualizer[T]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  42. def convertToLegacyEqualizer[T](left: T): LegacyEqualizer[T]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  43. def createTestInputStream[T](sc: SparkContext, ssc_: TestStreamingContext, input: Seq[Seq[T]])(implicit arg0: ClassTag[T]): TestInputStream[T]

    Create an input stream for the provided input sequence.

    Create an input stream for the provided input sequence. This is done using TestInputStream as queueStream's are not checkpointable.

    Definition Classes
    StreamingSuiteCommon
  44. def defaultEquality[A]: Equality[A]

    Definition Classes
    TripleEqualsSupport
  45. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  46. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  47. val eventuallyTimeout: Timeout

    Definition Classes
    StreamingSuiteCommon
  48. final def execute: Unit

    Definition Classes
    Suite
  49. final def execute(testName: String, configMap: ConfigMap, color: Boolean, durations: Boolean, shortstacks: Boolean, fullstacks: Boolean, stats: Boolean): Unit

    Definition Classes
    Suite
  50. def expectedTestCount(filter: Filter): Int

    Definition Classes
    Suite → AbstractSuite
  51. def fail(cause: Throwable): Nothing

    Definition Classes
    Assertions
  52. def fail(message: String, cause: Throwable): Nothing

    Definition Classes
    Assertions
  53. def fail(message: String): Nothing

    Definition Classes
    Assertions
  54. def fail(): Nothing

    Definition Classes
    Assertions
  55. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  56. def framework: String

    Definition Classes
    StreamingSuiteCommon
  57. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  58. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  59. def ignore(testName: String, testTags: Tag*)(testFun: ⇒ Unit): Unit

    Attributes
    protected
    Definition Classes
    FunSuiteLike
  60. def info: Informer

    Attributes
    protected
    Definition Classes
    FunSuiteLike → Informing
  61. def intercept[T <: AnyRef](f: ⇒ Any)(implicit manifest: Manifest[T]): T

    Definition Classes
    Assertions
  62. val invokeBeforeAllAndAfterAllEvenIfNoTestsAreExpected: Boolean

    Definition Classes
    BeforeAndAfterAll
  63. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  64. def isTraceEnabled(): Boolean

    Attributes
    protected
    Definition Classes
    Logging
  65. def log: Logger

    Attributes
    protected
    Definition Classes
    Logging
  66. def logDebug(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  67. def logDebug(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  68. def logError(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  69. def logError(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  70. def logInfo(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  71. def logInfo(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  72. def logName: String

    Attributes
    protected
    Definition Classes
    Logging
  73. def logTrace(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  74. def logTrace(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  75. def logWarning(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  76. def logWarning(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  77. def lowPriorityConversionCheckedConstraint[A, B](implicit equivalenceOfB: Equivalence[B], cnv: (A) ⇒ B): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  78. def lowPriorityTypeCheckedConstraint[A, B](implicit equivalenceOfB: Equivalence[B], ev: <:<[A, B]): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  79. def markup: Documenter

    Attributes
    protected
    Definition Classes
    FunSuiteLike → Documenting
  80. def master: String

    Definition Classes
    StreamingSuiteCommon
  81. def maxWaitTimeMillis: Int

    Definition Classes
    StreamingSuiteCommon
  82. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  83. def nestedSuites: IndexedSeq[Suite]

    Definition Classes
    Suite → AbstractSuite
  84. def note: Notifier

    Attributes
    protected
    Definition Classes
    FunSuiteLike → Notifying
  85. final def notify(): Unit

    Definition Classes
    AnyRef
  86. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  87. def numInputPartitions: Int

    Definition Classes
    StreamingSuiteCommon
  88. def pending: PendingNothing

    Definition Classes
    Suite
  89. def pendingUntilFixed(f: ⇒ Unit): Unit

    Definition Classes
    Suite
  90. final def registerIgnoredTest(testText: String, testTags: Tag*)(testFun: ⇒ Unit): Unit

    Definition Classes
    FunSuiteLike → TestRegistration
  91. final def registerTest(testText: String, testTags: Tag*)(testFun: ⇒ Unit): Unit

    Definition Classes
    FunSuiteLike → TestRegistration
  92. def rerunner: Option[String]

    Definition Classes
    Suite → AbstractSuite
  93. def run(testName: Option[String], args: Args): Status

    Definition Classes
    BeforeAndAfterAll → SuiteMixin
  94. final def run(testName: Option[String], reporter: Reporter, stopper: Stopper, filter: Filter, configMap: Map[String, Any], distributor: Option[Distributor], tracker: Tracker): Status

    Definition Classes
    AbstractSuite
  95. def runNestedSuites(args: Args): Status

    Attributes
    protected
    Definition Classes
    Suite → AbstractSuite
  96. def runStreams[V](outputStream: TestOutputStream[V], ssc: TestStreamingContext, numBatches: Int, numExpectedOutput: Int)(implicit arg0: ClassTag[V]): Seq[Seq[V]]

    Runs the streams set up in ssc on manual clock for numBatches batches and returns the collected output.

    Runs the streams set up in ssc on manual clock for numBatches batches and returns the collected output. It will wait until numExpectedOutput number of output data has been collected or timeout (set by maxWaitTimeMillis) is reached.

    Returns a sequence of items for each RDD.

    Definition Classes
    StreamingSuiteBase → StreamingSuiteCommon
  97. def runTest(testName: String, args: Args): Status

    Attributes
    protected
    Definition Classes
    FunSuiteLike → Suite → AbstractSuite
  98. def runTests(testName: Option[String], args: Args): Status

    Attributes
    protected
    Definition Classes
    FunSuiteLike → Suite → AbstractSuite
  99. def sc: SparkContext

  100. def setupClock(): SparkConf

    Definition Classes
    StreamingSuiteCommon
  101. def setupStreams[U, V, W](input1: Seq[Seq[U]], input2: Seq[Seq[V]], operation: (DStream[U], DStream[V]) ⇒ DStream[W])(implicit arg0: ClassTag[U], arg1: ClassTag[V], arg2: ClassTag[W]): (TestOutputStream[W], TestStreamingContext)

    Set up required DStreams to test the binary operation using the sequence of input collections.

    Set up required DStreams to test the binary operation using the sequence of input collections.

    Definition Classes
    StreamingSuiteCommon
  102. def setupStreams[U, V](input: Seq[Seq[U]], operation: (DStream[U]) ⇒ DStream[V], numPartitions: Int = numInputPartitions)(implicit arg0: ClassTag[U], arg1: ClassTag[V]): (TestOutputStream[V], TestStreamingContext)

    Set up required DStreams to test the DStream operation using the two sequences of input collections.

    Set up required DStreams to test the DStream operation using the two sequences of input collections.

    Definition Classes
    StreamingSuiteCommon
  103. final val styleName: String

    Definition Classes
    FunSuiteLike → Suite → AbstractSuite
  104. def suiteId: String

    Definition Classes
    Suite
  105. def suiteName: String

    Definition Classes
    Suite
  106. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  107. def tags: Map[String, Set[String]]

    Definition Classes
    FunSuiteLike → Suite → AbstractSuite
  108. def test(testName: String, testTags: Tag*)(testFun: ⇒ Unit): Unit

    Attributes
    protected
    Definition Classes
    FunSuiteLike
  109. def testDataFor(testName: String, theConfigMap: ConfigMap): TestData

    Definition Classes
    FunSuiteLike → Suite
  110. def testNames: Set[String]

    Definition Classes
    FunSuiteLike → Suite → AbstractSuite
  111. def testOperation[U, V, W](input1: Seq[Seq[U]], input2: Seq[Seq[V]], operation: (DStream[U], DStream[V]) ⇒ DStream[W], expectedOutput: Seq[Seq[W]], numBatches: Int, ordered: Boolean)(implicit arg0: ClassTag[U], arg1: ClassTag[V], arg2: ClassTag[W], equality: Equality[W]): Unit

    Test binary DStream operation with two lists of inputs

    Test binary DStream operation with two lists of inputs

    input1

    First sequence of input collections

    input2

    Second sequence of input collections

    operation

    Binary DStream operation to be applied to the 2 inputs

    expectedOutput

    Sequence of expected output collections

    numBatches

    Number of batches to run the operation for

    ordered

    Compare the output values with the expected output values ordered or not. Comparing doubles may not work well in case of unordered.

  112. def testOperation[U, V, W](input1: Seq[Seq[U]], input2: Seq[Seq[V]], operation: (DStream[U], DStream[V]) ⇒ DStream[W], expectedOutput: Seq[Seq[W]], ordered: Boolean)(implicit arg0: ClassTag[U], arg1: ClassTag[V], arg2: ClassTag[W], equality: Equality[W]): Unit

    Test binary DStream operation with two lists of inputs, with number of batches to run same as the number of expected output values

    Test binary DStream operation with two lists of inputs, with number of batches to run same as the number of expected output values

    ordered

    Compare the output values with the expected output values ordered or not. Comparing doubles may not work well in case of unordered.

  113. def testOperation[U, V](input: Seq[Seq[U]], operation: (DStream[U]) ⇒ DStream[V], expectedOutput: Seq[Seq[V]], numBatches: Int, ordered: Boolean)(implicit arg0: ClassTag[U], arg1: ClassTag[V], equality: Equality[V]): Unit

    Test unary DStream operation with a list of inputs

    Test unary DStream operation with a list of inputs

    input

    Sequence of input collections

    operation

    Binary DStream operation to be applied to the 2 inputs

    expectedOutput

    Sequence of expected output collections

    numBatches

    Number of batches to run the operation for

    ordered

    Compare the output values with the expected output values ordered or not. Comparing doubles may not work well in case of unordered.

  114. def testOperation[U, V](input: Seq[Seq[U]], operation: (DStream[U]) ⇒ DStream[V], expectedOutput: Seq[Seq[V]], ordered: Boolean = false)(implicit arg0: ClassTag[U], arg1: ClassTag[V], equality: Equality[V]): Unit

    Test unary DStream operation with a list of inputs, with number of batches to run same as the number of expected output values

    Test unary DStream operation with a list of inputs, with number of batches to run same as the number of expected output values

    ordered

    Compare the output values with the expected output values ordered or not. Comparing doubles may not work well in case of unordered.

  115. def testsFor(unit: Unit): Unit

    Attributes
    protected
    Definition Classes
    FunSuiteLike
  116. def toString(): String

    Definition Classes
    FunSuite → AnyRef → Any
  117. def trap[T](f: ⇒ T): Throwable

    Definition Classes
    Assertions
  118. def typeCheckedConstraint[A, B](implicit equivalenceOfA: Equivalence[A], ev: <:<[B, A]): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  119. implicit def unconstrainedEquality[A, B](implicit equalityOfA: Equality[A]): Constraint[A, B]

    Definition Classes
    TripleEquals → TripleEqualsSupport
  120. def useManualClock: Boolean

    Definition Classes
    StreamingSuiteCommon
  121. def verifyOutput[V](output: Seq[Seq[V]], expectedOutput: Seq[Seq[V]], ordered: Boolean)(implicit arg0: ClassTag[V], equality: Equality[V]): Unit

    Verify whether the output values after running a DStream operation is same as the expected output values, by comparing the output collections either as lists (order matters) or sets (order does not matter)

    Verify whether the output values after running a DStream operation is same as the expected output values, by comparing the output collections either as lists (order matters) or sets (order does not matter)

    ordered

    Compare the output values with the expected output values ordered or not. Comparing doubles may not work well in case of unordered.

  122. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  123. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  124. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  125. def withClue[T](clue: Any)(fun: ⇒ T): T

    Definition Classes
    Assertions
  126. def withFixture(test: NoArgTest): Outcome

    Attributes
    protected
    Definition Classes
    Suite → AbstractSuite
  127. def withOutputAndStreamingContext[R](outputStreamSSC: (TestOutputStream[R], TestStreamingContext))(block: (TestOutputStream[R], TestStreamingContext) ⇒ Unit): Unit

    Run a block of code with the given StreamingContext and automatically stop the context when the block completes or when an exception is thrown.

    Run a block of code with the given StreamingContext and automatically stop the context when the block completes or when an exception is thrown.

    Definition Classes
    StreamingSuiteCommon

Deprecated Value Members

  1. def afterAll(configMap: ConfigMap): Unit

    Attributes
    protected
    Definition Classes
    BeforeAndAfterAll
    Annotations
    @deprecated
    Deprecated

    Please use the afterAll(ConfigMap) method of trait BeforeAndAfterAllConfigMap instead.

  2. def assert(o: Option[String]): Unit

    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    This method has been deprecated in favor of macro assertion and will be removed in a future version of ScalaTest. If you need this, please copy the source code into your own trait instead.

  3. def assert(o: Option[String], clue: Any): Unit

    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    This method has been deprecated in favor of macro assertion and will be removed in a future version of ScalaTest. If you need this, please copy the source code into your own trait instead.

  4. def assume(o: Option[String]): Unit

    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    This method has been deprecated in favor of macro assumption and will be removed in a future version of ScalaTest. If you need this, please copy the source code into your own trait instead.

  5. def assume(o: Option[String], clue: Any): Unit

    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    This method has been deprecated in favor of macro assumption and will be removed in a future version of ScalaTest. If you need this, please copy the source code into your own trait instead.

  6. def beforeAll(configMap: ConfigMap): Unit

    Attributes
    protected
    Definition Classes
    BeforeAndAfterAll
    Annotations
    @deprecated
    Deprecated

    Please use the beforeAll(ConfigMap) method of trait BeforeAndAfterAllConfigMap instead.

  7. def expect(expected: Any)(actual: Any): Unit

    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    This expect method has been deprecated. Please replace all invocations of expect with an identical invocation of assertResult instead.

  8. def expect(expected: Any, clue: Any)(actual: Any): Unit

    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    This expect method has been deprecated. Please replace all invocations of expect with an identical invocation of assertResult instead.

  9. def expectResult(expected: Any)(actual: Any): Unit

    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    This expectResult method has been deprecated. Please replace all invocations of expectResult with an identical invocation of assertResult instead.

  10. def expectResult(expected: Any, clue: Any)(actual: Any): Unit

    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    This expectResult method has been deprecated. Please replace all invocations of expectResult with an identical invocation of assertResult instead.

Inherited from SharedSparkContext

Inherited from StreamingSuiteCommon

Inherited from SparkContextProvider

Inherited from Logging

Inherited from BeforeAndAfterAll

Inherited from SuiteMixin

Inherited from FunSuite

Inherited from FunSuiteLike

Inherited from Documenting

Inherited from Alerting

Inherited from Notifying

Inherited from Informing

Inherited from TestRegistration

Inherited from Suite

Inherited from Serializable

Inherited from AbstractSuite

Inherited from Assertions

Inherited from TripleEquals

Inherited from TripleEqualsSupport

Inherited from AnyRef

Inherited from Any

Ungrouped