public class KVUtils
extends Object
Constructor and Description |
---|
KVUtils() |
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 void |
org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1) |
static org.slf4j.Logger |
org$apache$spark$internal$Logging$$log_() |
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.
|
public static <M> org.apache.spark.util.kvstore.LevelDB open(java.io.File path, M metadata, scala.reflect.ClassTag<M> evidence$1)
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)public static <T> scala.collection.Seq<T> viewToSeq(org.apache.spark.util.kvstore.KVStoreView<T> view, int max, scala.Function1<T,Object> filter)
public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)