Packages

object ExtractPairs

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ExtractPairs
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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( ... ) @native() @IntrinsicCandidate()
  6. def createTuples(key1: String, key2: String, ts1: List[(String, Int)], ts2: List[(String, Int)], lookback: Int, last_checked: LastChecked, trace_id: String): List[PairFull]
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def extract(singleRDD: RDD[InvertedSingleFull], last_checked: RDD[LastChecked], lookback: Int): (RDD[PairFull], RDD[LastChecked])

    Extracts the event type pairs from an RDD that contains the complete traces.

    Extracts the event type pairs from an RDD that contains the complete traces. If there are previously indexed pairs this process will only calculate the new event type pairs by utilizing the information stored in the LastChecked table. Additionally, there will be no event type pair where the two events will have greater time difference than the one described by the parameter lookback.

    The generated pairs follow a Skip-till-next-match policy without overlapping in time. That is, in order to be two occurrences of the same event type pair in a trace, the second one must start after the first one has ended. For example: the trace t1 = (a,b,c,a,b) contains 2 occurrences of the event type (a,b). However, the trace t2 = (a,a,c,b,b) only contains one occurrence of the previous event type pair.

    singleRDD

    The RDD that contains the complete single inverted index

    last_checked

    The loaded values from the LastChecked table (it should be null if it is the first time that events are indexed in this log database).

    lookback

    The parameter that describes the maximum time difference that two events can have in order to create an event type pair.

    returns

    Two RDDs: (1) The first one that contains all the extracted event type pairs and (2) the second one contains the last timestamp of each event type pair for each trace.

  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  16. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  17. def toString(): String
    Definition Classes
    AnyRef → Any
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

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

Inherited from AnyRef

Inherited from Any

Ungrouped