kafka.log

SkimpyOffsetMap

class SkimpyOffsetMap extends OffsetMap

An hash table used for deduplicating the log. This hash table uses a cryptographicly secure hash of the key as a proxy for the key for comparisons and to save space on object overhead. Collisions are resolved by probing. This hash table does not support deletes.

Annotations
@nonthreadsafe()
Linear Supertypes
OffsetMap, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. SkimpyOffsetMap
  2. OffsetMap
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SkimpyOffsetMap(memory: Int, hashAlgorithm: String = "MD5")

    memory

    The amount of memory this map can use

    hashAlgorithm

    The hash algorithm instance to use: MD2, MD5, SHA-1, SHA-256, SHA-384, SHA-512

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. val bytesPerEntry: Int

    The number of bytes of space each entry uses (the number of bytes in the hash plus an 8 byte offset)

  6. def clear(): Unit

    Change the salt used for key hashing making all existing keys unfindable.

    Change the salt used for key hashing making all existing keys unfindable. Doesn't actually zero out the array.

    Definition Classes
    SkimpyOffsetMapOffsetMap
  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. def collisionRate: Double

    The rate of collisions in the lookups

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

    Definition Classes
    AnyRef
  10. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  11. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  12. def get(key: ByteBuffer): Long

    Get the offset associated with this key.

    Get the offset associated with this key.

    key

    The key

    returns

    The offset associated with this key or -1 if the key is not found

    Definition Classes
    SkimpyOffsetMapOffsetMap
  13. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  14. val hashAlgorithm: String

    The hash algorithm instance to use: MD2, MD5, SHA-1, SHA-256, SHA-384, SHA-512

  15. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  16. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  17. val memory: Int

    The amount of memory this map can use

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

    Definition Classes
    AnyRef
  19. final def notify(): Unit

    Definition Classes
    AnyRef
  20. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  21. def put(key: ByteBuffer, offset: Long): Unit

    Associate this offset to the given key.

    Associate this offset to the given key.

    key

    The key

    offset

    The offset

    Definition Classes
    SkimpyOffsetMapOffsetMap
  22. def size: Int

    The number of entries put into the map (note that not all may remain)

    The number of entries put into the map (note that not all may remain)

    Definition Classes
    SkimpyOffsetMapOffsetMap
  23. val slots: Int

    The maximum number of entries this map can contain

    The maximum number of entries this map can contain

    Definition Classes
    SkimpyOffsetMapOffsetMap
  24. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  25. def toString(): String

    Definition Classes
    AnyRef → Any
  26. def utilization: Double

    Definition Classes
    OffsetMap
  27. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from OffsetMap

Inherited from AnyRef

Inherited from Any

Ungrouped