KVStore-spark技术分享

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;
}

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

KVStore

KVStore

相关推荐

欢迎关注：spark技术分享

热门标签

近期文章

分类目录

关注公众号：spark技术分享

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏

QQ咨询

回顶部