Packages

class FlinkTestScenarioRunner extends ClassBasedTestScenarioRunner

Linear Supertypes
ClassBasedTestScenarioRunner, TestScenarioRunner, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FlinkTestScenarioRunner
  2. ClassBasedTestScenarioRunner
  3. TestScenarioRunner
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new FlinkTestScenarioRunner(components: List[ComponentDefinition], globalVariables: Map[String, AnyRef], config: Config, flinkMiniCluster: FlinkMiniClusterHolder, componentUseCase: ComponentUseCase)

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  6. val components: List[ComponentDefinition]
  7. val config: Config
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  11. val globalVariables: Map[String, AnyRef]
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  17. def runWithData[I, R](scenario: CanonicalProcess, data: List[I], boundedness: Boundedness = Boundedness.CONTINUOUS_UNBOUNDED, timestampAssigner: Option[TimestampWatermarkHandler[I]] = None, nodesData: NodesDeploymentData = NodesDeploymentData.empty, processVersion: ProcessVersion = ProcessVersion.empty)(implicit arg0: ClassTag[I]): RunnerListResult[R]
  18. def runWithData[I, R](scenario: CanonicalProcess, data: List[I])(implicit arg0: ClassTag[I]): RunnerListResult[R]
    Definition Classes
    FlinkTestScenarioRunner → ClassBasedTestScenarioRunner
  19. def runWithDataIgnoringResults[I](scenario: CanonicalProcess, data: List[I], nodesData: NodesDeploymentData = NodesDeploymentData.empty, processVersion: ProcessVersion = ProcessVersion.empty)(implicit arg0: ClassTag[I]): RunnerResultUnit

    Can be used to test Flink based sinks.

  20. def runWithDataWithType[I, R](scenario: CanonicalProcess, data: List[I], inputType: TypingResult, boundedness: Boundedness = Boundedness.CONTINUOUS_UNBOUNDED, timestampAssigner: Option[TimestampWatermarkHandler[I]] = None, nodesData: NodesDeploymentData = NodesDeploymentData.empty, processVersion: ProcessVersion = ProcessVersion.empty): RunnerListResult[R]
  21. def runWithoutData[R](scenario: CanonicalProcess, nodesData: NodesDeploymentData = NodesDeploymentData.empty, processVersion: ProcessVersion = ProcessVersion.empty): RunnerListResult[R]

    Can be used to test Flink bounded sources - we wait for the scenario to finish.

  22. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from ClassBasedTestScenarioRunner

Inherited from TestScenarioRunner

Inherited from AnyRef

Inherited from Any

Ungrouped