Packages

final case class RightReducer(k: Int, forwardOnly: Boolean, intersect: Boolean) extends CountReducer with Product with Serializable

Implements the com.jnpersson.discount.spark.Rule.Right reduction rule

Linear Supertypes
Serializable, Serializable, Product, Equals, CountReducer, Reducer, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RightReducer
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. CountReducer
  7. Reducer
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RightReducer(k: Int, forwardOnly: Boolean, intersect: Boolean)

Value Members

  1. val forwardOnly: Boolean

    Whether to include only canonical (forward oriented) k-mers when reducing

    Whether to include only canonical (forward oriented) k-mers when reducing

    Definition Classes
    RightReducerReducer
  2. def hasNonZeroTag(tags: Array[Tag]): Boolean
    Definition Classes
    Reducer
  3. val intersect: Boolean
    Definition Classes
    RightReducerCountReducer
  4. val k: Int
    Definition Classes
    RightReducerReducer
  5. def preprocessFirst(bucket: ReducibleBucket): ReducibleBucket

    Preprocess bucket A prior to op(A,B)

    Preprocess bucket A prior to op(A,B)

    Definition Classes
    Reducer
  6. def preprocessSecond(bucket: ReducibleBucket): ReducibleBucket

    Preprocess bucket B prior to op(A,B)

    Preprocess bucket B prior to op(A,B)

    Definition Classes
    Reducer
  7. def reduceCounts(count1: Tag, count2: Tag): Tag
    Definition Classes
    RightReducerCountReducer
  8. def reduceEqualKmers(table: KmerTable, into: Int, from: Int): Unit

    Apply a binary operation op(into, from) on the tags of the k-mers at these positions, writing the result in the tags of "into", writing the zero value into the tags of "from".

    Apply a binary operation op(into, from) on the tags of the k-mers at these positions, writing the result in the tags of "into", writing the zero value into the tags of "from". This method will only be called on equal k-mers.

    table

    The table containing k-mers

    into

    Target k-mer index in the table (k-mer A in op(A,B))

    from

    Source k-mer index in the table (k-mer B in op(A,B))

    Definition Classes
    CountReducerReducer
  9. def shouldKeep(table: KmerTable, kmer: Int): Boolean

    Whether to keep the k-mer (together with tag data) after reduction.

    Whether to keep the k-mer (together with tag data) after reduction.

    table

    The table containing k-mers

    kmer

    Index of k-mer to be tested

    Definition Classes
    CountReducerReducer
  10. val tagOffset: Int
    Definition Classes
    CountReducerReducer
  11. val zeroValue: Tag

    A special value that is used to indicate non-existent/redundant k-mers.

    A special value that is used to indicate non-existent/redundant k-mers. Should also have the property that op(A, zero) == op(zero, A) for all A

    Definition Classes
    Reducer