final case class MaxReducer(k: Int, forwardOnly: Boolean, intersect: Boolean) extends CountReducer with Product with Serializable
Implements the com.jnpersson.discount.spark.Rule.Max reduction rule
- Alphabetic
 - By Inheritance
 
- MaxReducer
 - Serializable
 - Serializable
 - Product
 - Equals
 - CountReducer
 - Reducer
 - AnyRef
 - Any
 
- Hide All
 - Show All
 
- Public
 - All
 
Instance Constructors
-  new MaxReducer(k: Int, forwardOnly: Boolean, intersect: Boolean)
 
Value Members
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        !=(arg0: Any): Boolean
      
      
      
- Definition Classes
 - AnyRef → Any
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        ##(): Int
      
      
      
- Definition Classes
 - AnyRef → Any
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        ==(arg0: Any): Boolean
      
      
      
- Definition Classes
 - AnyRef → Any
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        asInstanceOf[T0]: T0
      
      
      
- Definition Classes
 - Any
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        clone(): AnyRef
      
      
      
- Attributes
 - protected[lang]
 - Definition Classes
 - AnyRef
 - Annotations
 - @throws( ... ) @native()
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        eq(arg0: AnyRef): Boolean
      
      
      
- Definition Classes
 - AnyRef
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        finalize(): Unit
      
      
      
- Attributes
 - protected[lang]
 - Definition Classes
 - AnyRef
 - Annotations
 - @throws( classOf[java.lang.Throwable] )
 
 - 
      
      
      
        
      
    
      
        
        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
 - MaxReducer → Reducer
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        getClass(): Class[_]
      
      
      
- Definition Classes
 - AnyRef → Any
 - Annotations
 - @native()
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        hasNonZeroTag(tags: Array[Tag]): Boolean
      
      
      
- Definition Classes
 - Reducer
 
 - 
      
      
      
        
      
    
      
        
        val
      
      
        intersect: Boolean
      
      
      
- Definition Classes
 - MaxReducer → CountReducer
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        isInstanceOf[T0]: Boolean
      
      
      
- Definition Classes
 - Any
 
 - 
      
      
      
        
      
    
      
        
        val
      
      
        k: Int
      
      
      
- Definition Classes
 - MaxReducer → Reducer
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        ne(arg0: AnyRef): Boolean
      
      
      
- Definition Classes
 - AnyRef
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        notify(): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @native()
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        notifyAll(): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @native()
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        preprocessFirst(bucket: ReducibleBucket): ReducibleBucket
      
      
      
Preprocess bucket A prior to op(A,B)
Preprocess bucket A prior to op(A,B)
- Definition Classes
 - Reducer
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        preprocessSecond(bucket: ReducibleBucket): ReducibleBucket
      
      
      
Preprocess bucket B prior to op(A,B)
Preprocess bucket B prior to op(A,B)
- Definition Classes
 - Reducer
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        reduceCounts(count1: Tag, count2: Tag): Tag
      
      
      
- Definition Classes
 - MaxReducer → CountReducer
 
 - 
      
      
      
        
      
    
      
        
        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
 - CountReducer → Reducer
 
 - 
      
      
      
        
      
    
      
        
        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
 - CountReducer → Reducer
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        synchronized[T0](arg0: ⇒ T0): T0
      
      
      
- Definition Classes
 - AnyRef
 
 - 
      
      
      
        
      
    
      
        
        val
      
      
        tagOffset: Int
      
      
      
- Definition Classes
 - CountReducer → Reducer
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @throws( ... )
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(arg0: Long, arg1: Int): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @throws( ... )
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(arg0: Long): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @throws( ... ) @native()
 
 - 
      
      
      
        
      
    
      
        
        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