flink

Type Members

1. trait DataStreamTLProperty extends AnyRef

   

2. case class FlinkFormula[T](formula: Formula[T], discretizer: StreamDiscretizer) extends Product with Serializable

   

3. case class FlinkNextFormula[T](formula: NextFormula[T]) extends Product with Serializable

   

4. case class Parallelism(numPartitions: Int) extends Product with Serializable

   

   Used to specify a default parallelism for Flink

5. trait StreamDiscretizer extends AnyRef

   

6. class TestCaseContext[In, Out] extends Serializable

   

   Runs a test case by 1.

   Runs a test case by 1. Exercise the test case: generate an input DataStream from testCase and an output DataStream applying testSubject to the input, and persist both streams 2. Evaluate the test case exercise: read the persisted input and output streams, and evaluate formulaNext on a discretization of them

7. case class TimedElement[T](timestamp: Long, value: T) extends Product with Serializable

   
   timestamp

   milliseconds since epoch

8. case class TimedWindow[T](timestamp: Long, data: DataSet[TimedElement[T]]) extends Product with Serializable

   

   Represents a time window with timed values.

   Represents a time window with timed values. Note timestamp can be smaller than the earlier element in data, for example in a tumbling window where a new event starts at a regular rate, independently of the actual elements in the window

   timestamp

   milliseconds since epoch for the start of the window