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: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. val bytesPerEntry: Int

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

  8. 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
  9. def clone(): AnyRef

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

    The rate of collisions in the lookups

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

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

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

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. 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
  15. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  16. val hashAlgorithm: String

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

  17. def hashCode(): Int

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

    Definition Classes
    Any
  19. val memory: Int

    The amount of memory this map can use

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

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

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

    Definition Classes
    AnyRef
  23. 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
  24. 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
  25. val slots: Int

    The maximum number of entries this map can contain

    The maximum number of entries this map can contain

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

    Definition Classes
    AnyRef
  27. def toString(): String

    Definition Classes
    AnyRef → Any
  28. def utilization: Double

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from OffsetMap

Inherited from AnyRef

Inherited from Any

Ungrouped