Packages

package gen

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. case class PStream[A](windows: Seq[Window[A]]) extends Seq[Window[A]] with Product with Serializable

    An object of this class represents a finite prefix of a discrete data streams, aka prefix DStream or just PDStream

  2. class PStreamGen[A] extends AnyRef
  3. trait PStreamMatchers extends AnyRef
  4. case class Window[A](points: Seq[A]) extends Seq[A] with Product with Serializable

    Objects of this class represent batches of elements in a discrete data stream

  5. class WindowGen[A] extends AnyRef

Value Members

  1. object BatchGenConversions

    Implicit conversions removed from BatchGen companion.

    Implicit conversions removed from BatchGen companion. This is needed because we cannot populate the name space with standard names for HO generators like of() or ofN(), but we also want to have these implicit conversions available

  2. object Buildables
  3. object PStream extends Serializable
  4. object PStreamGen

    All the temporal generators defined in this object are sized generators, but the size parameters only affects the number of batches in the output PDStream, not the size of the batches.

    All the temporal generators defined in this object are sized generators, but the size parameters only affects the number of batches in the output PDStream, not the size of the batches. The size of the batches can be changed by using Gen.resize in the definition of the batch generator that is passed to these HO generators

    On the other hand for generators of arbitrary PDStreams like Gen.resize(5, arbitrary[DStream[Int]]) Gen.resize has effect, both in the number of batches and in the size of the batches, as those arbitrary instances are based on arbitrary for lists

    TODO That should be tested // by using Gen.resize(5, TLGen.always(Batch(List(0, 1)))) (constant batch size) // and then in Gen.resize(3, TLGen.always(BatchGen.ofNtoM(1, 5, Gen.choose(0, 3)))) // the point is that we always have 3 batches, but Gen.resize doesn't affect the batch // size but only the number of batches //

  5. object PStreamGenConversions

    Implicit conversions removed from BatchGen companion.

    Implicit conversions removed from BatchGen companion. This is needed because we cannot populate the name space with standard names for HO generators like of() or ofN(), but we also want to have these implicit conversions available

  6. object PStreamMatchers extends PStreamMatchers
  7. object ReGen

    Generators for simple regexp, as generators of Seq[A]

  8. object UtilsGen
  9. object Window extends Serializable
  10. object WindowGen

    Generators for Batch, a class for representing batches of elements in a discrete data stream.

    Generators for Batch, a class for representing batches of elements in a discrete data stream. This is a local representation, but you can use import es.ucm.fdi.sscheck.gen.RDDGen._ to get an automatic conversion from Gen[Batch[A]] to Gen[RDD[A]]

    All the temporal generators defined in this object are sized generators, but the size parameters only affects the number of batches in the output DStream, not the size of the batches. The size of the batches can be changed by using Gen.resize in the definition of the batch generator that is passed to these HO generators

    On the other hand for generators of arbitrary DStreams like Gen.resize(5, arbitrary[DStream[Int]]) Gen.resize has effect, both in the number of batches and in the size of the batches, as those arbitrary instances are based on arbitrary for lists

    TODO That should be tested // by using Gen.resize(5, TLGen.always(Batch(List(0, 1)))) (constant batch size) // and then in Gen.resize(3, TLGen.always(BatchGen.ofNtoM(1, 5, Gen.choose(0, 3)))) // the point is that we always have 3 batches, but Gen.resize doesn't affect the batch // size but only the number of batches //

Ungrouped