org.apache.spark.streamdm.streams.generators

RandomRBFEventsGenerator

class RandomRBFEventsGenerator extends Generator

RandomRBFEventsGenerator generates data stream for Clustream via a random radial basis function.

It uses the following options:

Linear Supertypes
Generator, StreamReader, Configurable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. RandomRBFEventsGenerator
  2. Generator
  3. StreamReader
  4. Configurable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RandomRBFEventsGenerator()

Type Members

  1. class GeneratorCluster extends AnyRef

    A GeneratorCluster represents the cluster which contains some MicroCluster(represented by SphereCluster) in Clustream Algorithm.

Value Members

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

    Definition Classes
    AnyRef

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

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. def chooseWeightedElement(): Int

  8. val chunkSizeOption: IntOption

  9. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  10. var clusterIdCounter: Int

  11. val decayHorizonOption: IntOption

  12. val densityRangeOption: FloatOption

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

    Definition Classes
    AnyRef

  14. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  15. val eventDeleteCreateOption: FlagOption

  16. val eventFrequencyOption: IntOption

  17. val eventFrequencyRange: Int

  18. val eventMergeSplitOption: FlagOption

  19. def eventScheduler(): Unit

  20. def fadeIn(): String

  21. def fadeOut(): String

  22. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  23. def getChunkSize(): Int

    returns chunk size

    returns chunk size

    Definition Classes
    RandomRBFEventsGenerator → Generator

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

    Definition Classes
    AnyRef → Any

  25. def getExample(): Example

    generates a random example.

    generates a random example.

    returns

    a random example

    Definition Classes
    RandomRBFEventsGenerator → Generator

  26. def getExampleSpecification(): ExampleSpecification

    Obtains the specification of the examples in the stream.

    Obtains the specification of the examples in the stream.

    returns

    an ExampleSpecification of the features

    Definition Classes
    RandomRBFEventsGenerator → StreamReader

  27. def getExamples(length: Int = getChunkSize()): Array[Example]

    obtains an array of examples

    obtains an array of examples

    length

    size of the array; default chunkSizeOption.getValue

    returns

    an array of Examples

    Definition Classes
    Generator

  28. def getExamples(ssc: StreamingContext): DStream[Example]

    Obtains a stream of random examples.

    Obtains a stream of random examples.

    ssc

    a Spark Streaming context

    returns

    a stream of Examples

    Definition Classes
    Generator → StreamReader

  29. def getNextEvent(): Int

  30. def getNoisePoint(): Array[Double]

  31. def getslideDuration(): Int

    returns slide duration

    returns slide duration

    Definition Classes
    RandomRBFEventsGenerator → Generator

  32. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  33. def init(): Unit

    initializes the generator

    initializes the generator

    Definition Classes
    RandomRBFEventsGenerator → Generator

  34. def initKernels(): Unit

  35. var inited: Boolean

    Definition Classes
    Generator

  36. var instanceRandom: Random

  37. val instanceRandomSeedOption: IntOption

  38. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  39. val kernelMovePointFrequency: Int

  40. val kernelRadiiOption: FloatOption

  41. val kernelRadiiRangeOption: FloatOption

  42. var kernels: ArrayBuffer[GeneratorCluster]

  43. val maxDistanceMoveThresholdByStep: Double

  44. val maxOverlapFitRuns: Int

  45. var mergeClusterA: GeneratorCluster

  46. var mergeClusterB: GeneratorCluster

  47. def mergeKernels(steps: Int): String

  48. var mergeKernelsOverlapping: Boolean

  49. val merge_threshold: Double

  50. val modelRandomSeedOption: IntOption

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

    Definition Classes
    AnyRef

  52. var nextEventChoice: Int

  53. var nextEventCounter: Int

  54. val noiseInClusterOption: FlagOption

  55. val noiseLevelOption: FloatOption

  56. def normalizeWeights(): Unit

  57. final def notify(): Unit

    Definition Classes
    AnyRef

  58. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  59. var numActiveKernels: Int

  60. val numClusterOption: IntOption

  61. val numClusterRangeOption: IntOption

  62. val numFeaturesOption: IntOption

  63. var numGeneratedInstances: Int

  64. val slideDurationOption: IntOption

  65. val speedOption: IntOption

  66. val speedRangeOption: IntOption

  67. def splitKernel(): String

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

    Definition Classes
    AnyRef

  69. def toString(): String

    Definition Classes
    AnyRef → Any

  70. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Generator

Inherited from StreamReader

Inherited from Configurable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped