DataStreamTLProperty

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 buildFreshExecutionEnvironment(): ExecutionEnvironment

   
   returns

   a newly created ExecutionEnvironment, for which no data set or action has been defined, and that it's not started

6. def buildFreshStreamExecutionEnvironment(): StreamExecutionEnvironment

   

   If override the returned environment should have event time set.

   If override the returned environment should have event time set.

   returns

   a newly created StreamExecutionEnvironment, for which no stream or action has been defined, and that it's not started.

7. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. def defaultParallelism: Parallelism

   

   Override for custom configuration

9. final def eq(arg0: AnyRef): Boolean

   

   Definition Classes

   AnyRef

10. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

11. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

12. def forAllDataStream[In, Out](generator: TSGen[In])(testSubject: (DataStream[In]) ⇒ DataStream[Out])(formula: FlinkFormula[Letter[In, Out]])(implicit arg0: TypeInformation[In], arg1: TypeInformation[Out], pp1: (TSGen[In]) ⇒ Pretty): Prop

    
    returns

    a ScalaCheck property that is executed by:

    • generating an input DataStream: we generate a sequence of TimedElement with generator, and then we build a DataStream[In] from it by using the timestamp of each element as its **event time**, and then discarding the timestamp. Elements in the generated sequence are expected to be sorted by timestamp in ascending order.
    • generating an output DataStream applying testSubject on the input DataStream
    • checking formula.formula on a discretization of those DataStream created by formula.discretizer The property is satisfied iff all the test cases satisfy the formula. A new streaming context is created for each test case to isolate its execution. Note: this assumes a stream execution environment configured with event time, which is used to get more deterministic behaviour, and to place the generated elements on the stream.

13. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

14. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

15. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

16. def maxNumberLettersPerTestCase: Int

    

    Override for custom configuration

    Override for custom configuration

    Maximum number of letters (i.e., tumbling windows) that the test case will wait for, 100 by default

17. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

18. final def notify(): Unit

    

    Definition Classes

    AnyRef

19. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

20. def showNSampleElementsOnEvaluation: Int

    

    How many elements of each window to print during test case evaluation

21. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

22. def toString(): String

    

    Definition Classes

    AnyRef → Any

23. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

24. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

25. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )