spark-core-KVStore.adoc

KVStore

KVStore is the contract of…​FIXME

package org.apache.spark.util.kvstore;

public interface KVStore extends Closeable {
  long count(Class<?> type) throws Exception;
  long count(Class<?> type, String index, Object indexedValue) throws Exception;
  void delete(Class<?> type, Object naturalKey) throws Exception;
  <T> T getMetadata(Class<T> klass) throws Exception;
  <T> T read(Class<T> klass, Object naturalKey) throws Exception;
  void setMetadata(Object value) throws Exception;
  <T> KVStoreView<T> view(Class<T> type) throws Exception;
  void write(Object value) throws Exception;
}

Note	KVStore is a @Private contract that is to mark a Java interface as if it were private[spark].

Table 1. KVStore Contract

Method	Description
view	Used when…​FIXME

Table 2. KVStores

KVStore	Description
ElementTrackingStore
InMemoryStore
LevelDB