com.twitter.summingbird.scalding

store

package store

Visibility
  1. Public
  2. All

Type Members

  1. class DirectoryBatchedStore[K <: Writable, V <: Writable] extends BatchedStore[K, V]

    DirectoryBatched Scalding Store, which only contains (K, V) data pairs in the data.

  2. class InitialBatchedStore[K, V] extends ProxyBatchedStore[K, V]

    For (firstNonZero - 1) we read empty.

  3. abstract class ProxyBatchedStore[K, V] extends BatchedStore[K, V]

    Use this class to easily change, for instance, the pruning for an existing store.

  4. class VersionedBatchStore[K, V, K2, V2] extends VersionedBatchStoreBase[K, V]

  5. abstract class VersionedBatchStoreBase[K, V] extends BatchedStore[K, V]

    Allows subclasses to share the means of reading version numbers but plug in methods to actually read or write the data.

Value Members

  1. object VersionedBatchStore extends Serializable

    Scalding implementation of the batch read and write components of a store that uses the VersionedKeyValSource from scalding-commons.

  2. object VersionedStore

    Scalding implementation of the batch read and write components of a store that uses the VersionedKeyValSource from scalding-commons.

Ungrouped