Class

kafka.log

SkimpyOffsetMap

Related Doc: package log

Permalink

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
Visibility
  1. Public
  2. All

Instance Constructors

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

    Permalink

    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

    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. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. val bytesPerEntry: Int

    Permalink

    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

    Permalink

    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

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

    Permalink

    The rate of collisions in the lookups

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

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

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

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

    Permalink

    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[_]

    Permalink
    Definition Classes
    AnyRef → Any
  14. val hashAlgorithm: String

    Permalink

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

  15. def hashCode(): Int

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

    Permalink
    Definition Classes
    Any
  17. val memory: Int

    Permalink

    The amount of memory this map can use

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

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

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

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

    Permalink

    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

    Permalink

    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

    Permalink

    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

    Permalink
    Definition Classes
    AnyRef
  25. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  26. def utilization: Double

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

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

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

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

Inherited from OffsetMap

Inherited from AnyRef

Inherited from Any

Ungrouped