org.apache.spark.status

Class KVUtils

Object

org.apache.spark.status.KVUtils

public class KVUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
KVUtils()

Method Summary

Modifier and Type	Method and Description
static <M> org.apache.spark.util.kvstore.LevelDB	open(java.io.File path, M metadata, scala.reflect.ClassTag<M> evidence$1) Open or create a LevelDB store.
static <T> scala.collection.Seq<T>	viewToSeq(org.apache.spark.util.kvstore.KVStoreView<T> view, int max, scala.Function1<T,Object> filter) Turns a KVStoreView into a Scala sequence, applying a filter.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KVUtils

public KVUtils()

Method Detail

open

public static <M> org.apache.spark.util.kvstore.LevelDB open(java.io.File path,
                                                             M metadata,
                                                             scala.reflect.ClassTag<M> evidence$1)

Open or create a LevelDB store.

Parameters:

path - Location of the store.

metadata - Metadata value to compare to the data in the store. If the store does not contain any metadata (e.g. it's a new store), this value is written as the store's metadata.

evidence$1 - (undocumented)

Returns:

(undocumented)

viewToSeq

public static <T> scala.collection.Seq<T> viewToSeq(org.apache.spark.util.kvstore.KVStoreView<T> view,
                                                    int max,
                                                    scala.Function1<T,Object> filter)

Turns a KVStoreView into a Scala sequence, applying a filter.