Class

org.apache.spark.sql.execution

ReservoirRegionSegmentMap

Related Doc: package execution

Permalink

class ReservoirRegionSegmentMap[V] extends ReentrantReadWriteLock with SegmentMap[Row, V] with Serializable

Created by vivekb on 21/10/16.

Linear Supertypes
Serializable, SegmentMap[Row, V], ReentrantReadWriteLock, Serializable, ReadWriteLock, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReservoirRegionSegmentMap
  2. Serializable
  3. SegmentMap
  4. ReentrantReadWriteLock
  5. Serializable
  6. ReadWriteLock
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ReservoirRegionSegmentMap(_reservoirRegion: PartitionedRegion, _columns: Array[Int], _types: Array[DataType], _numColumns: Int, qcsColHandler: Option[ColumnHandler], _segi: Int, _nsegs: Int, _sampleIsPartitioned: Boolean)(implicit arg0: ClassTag[V])

    Permalink

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

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

    Permalink
    Definition Classes
    AnyRef → Any

  4. val _columns: Array[Int]

    Permalink

  5. val _nsegs: Int

    Permalink

  6. val _numColumns: Int

    Permalink

  7. val _reservoirRegion: PartitionedRegion

    Permalink

  8. val _segi: Int

    Permalink

  9. val _types: Array[DataType]

    Permalink

  10. def apply(k: Row, hash: Int): V

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  11. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  12. def beforeSegmentEnd(): AnyRef

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  13. def changeValue(r: Row, bucketId: Int, change: ChangeValue[Row, V], isLocal: Boolean): Boolean

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  14. def clearBucket(): Unit

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  15. def clone(): AnyRef

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

  16. def contains(k: Row, hash: Int): Boolean

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  17. def currentRow(newRow: ReusableRow, row: Row, bucketId: Int): ReusableRow

    Permalink

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

    Permalink
    Definition Classes
    AnyRef

  19. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  20. def executeInReadLock[T](br: BucketRegion, body: ⇒ T, doLock: Boolean): T

    Permalink

  21. def executeInWriteLock[T](br: BucketRegion, body: ⇒ T, doLock: Boolean): T

    Permalink

  22. def finalize(): Unit

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

  23. def foldEntries[U](init: U, copyIfRequired: Boolean, f: (Row, V, U) ⇒ U): U

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  24. def foldValues[U](init: U, f: (Int, V, U) ⇒ U, reset: Boolean = false): U

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

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

    Permalink
    Definition Classes
    AnyRef → Any

  26. def getOwner(): Thread

    Permalink
    Attributes
    protected[java.util.concurrent.locks]
    Definition Classes
    ReentrantReadWriteLock

  27. final def getQueueLength(): Int

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  28. def getQueuedReaderThreads(): Collection[Thread]

    Permalink
    Attributes
    protected[java.util.concurrent.locks]
    Definition Classes
    ReentrantReadWriteLock

  29. def getQueuedThreads(): Collection[Thread]

    Permalink
    Attributes
    protected[java.util.concurrent.locks]
    Definition Classes
    ReentrantReadWriteLock

  30. def getQueuedWriterThreads(): Collection[Thread]

    Permalink
    Attributes
    protected[java.util.concurrent.locks]
    Definition Classes
    ReentrantReadWriteLock

  31. def getReadHoldCount(): Int

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  32. def getReadLockCount(): Int

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  33. def getWaitQueueLength(arg0: Condition): Int

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  34. def getWaitingThreads(arg0: Condition): Collection[Thread]

    Permalink
    Attributes
    protected[java.util.concurrent.locks]
    Definition Classes
    ReentrantReadWriteLock

  35. def getWriteHoldCount(): Int

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  36. final def hasQueuedThread(arg0: Thread): Boolean

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  37. final def hasQueuedThreads(): Boolean

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  38. def hasWaiters(arg0: Condition): Boolean

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  39. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  40. def isEmpty: Boolean

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  41. final def isFair(): Boolean

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  42. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  43. def isWriteLocked(): Boolean

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  44. def isWriteLockedByCurrentThread(): Boolean

    Permalink
    Definition Classes
    ReentrantReadWriteLock

  45. def iterator: Iterator[(Row, V)]

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

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

    Permalink
    Definition Classes
    AnyRef

  47. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  48. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  49. def readLock(): ReadLock

    Permalink
    Definition Classes
    ReentrantReadWriteLock → ReadWriteLock

  50. def segmentEnd(puts: AnyRef): Unit

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  51. def size: Int

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

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

    Permalink
    Definition Classes
    AnyRef

  53. def toString(): String

    Permalink
    Definition Classes
    ReentrantReadWriteLock → AnyRef → Any

  54. def update(k: Row, hash: Int, v: V): Boolean

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  55. var valid: Boolean

    Permalink
    Definition Classes
    SegmentMap

  56. def valuesIterator: Iterator[V]

    Permalink
    Definition Classes
    ReservoirRegionSegmentMap → SegmentMap

  57. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  60. def writeLock(): WriteLock

    Permalink
    Definition Classes
    ReentrantReadWriteLock → ReadWriteLock

Inherited from Serializable

Inherited from SegmentMap[Row, V]

Inherited from ReentrantReadWriteLock

Inherited from Serializable

Inherited from ReadWriteLock

Inherited from AnyRef

Inherited from Any

Ungrouped