Packages

class CachingRetriever extends Retriever with Serializable

Wraps a retriever and caches the payloads.

Note

Payloads retrieved as stream are not cached. Moreover statistics when retrieving as stream are updated only in case the stream is closed.

Linear Supertypes
Serializable, Serializable, Retriever, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CachingRetriever
  2. Serializable
  3. Serializable
  4. Retriever
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def getPayload(key: Key, meta: Meta, file: File): Payload

    Gets the Payload of a partition by its key.

    Gets the Payload of a partition by its key. This method always returns a file payload. Implementations of this method may be optimized so that the content in the retrieved partition is not fully loaded in memory.

    key

    the key

    meta

    the metadata

    file

    The file where the partition data must be copied into.

    returns

    the retrieved Payload

    Definition Classes
    CachingRetrieverRetriever
    Note

    It's the caller's responsibility to delete the file when it's no longer needed.

  11. def getPayload(key: Key, meta: Meta): Payload

    Gets the Payload of a partition by its key.

    Gets the Payload of a partition by its key.

    key

    the key

    meta

    the metadata

    returns

    the retrieved Payload

    Definition Classes
    CachingRetrieverRetriever
  12. def getPayloadAsInputStream(key: Key, meta: Meta): InputStream

    Gets the Payload of a partition by its key.

    Gets the Payload of a partition by its key. This method always returns an input stream.

    Please note that this method will not allow to cache the retrieved content.

    key

    the key

    meta

    the metadata

    returns

    the data retrieving stream

    Definition Classes
    CachingRetrieverRetriever
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from Serializable

Inherited from Serializable

Inherited from Retriever

Inherited from AnyRef

Inherited from Any

Ungrouped