final class SorterOps[K1, K2, V] extends AnyRef
- Annotations
- @nowarn()
- Source
- SCollectionSyntax.scala
- Alphabetic
- By Inheritance
- SorterOps
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SorterOps(self: SCollection[(K1, Iterable[(K2, V)])])(implicit arg0: SortingKey[K2])
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(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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 sortValues(memoryMB: Int)(implicit k1Coder: Coder[K1], k2Coder: Coder[K2], vCoder: Coder[V]): SCollection[(K1, Iterable[(K2, V)])]
Takes an SCollection with elements consisting of a primary key and iterables over (secondary key, value) pairs, and returns an SCollection of the same elements but with values sorted lexicographically by the secondary key.
Takes an SCollection with elements consisting of a primary key and iterables over (secondary key, value) pairs, and returns an SCollection of the same elements but with values sorted lexicographically by the secondary key.
The secondary key needs to be encoded as a String or Array[Byte. SortValues compares bytes lexicographically and may write secondary key-value pairs to disk.
- memoryMB
Sets the size of the memory buffer in megabytes. This controls both the buffer for initial in memory sorting and the buffer used when external sorting. Must be greater than zero and less than 2048.
- Annotations
- @experimental()
- Note
The primary key is explicit here only because this transform is typically used on a result of a com.spotify.scio.values.PairSCollectionFunctions.groupByKey.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()