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

results matching ""

    No results matching ""