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.KVStore	open(java.io.File path, M metadata, SparkConf conf, scala.reflect.ClassTag<M> evidence$1) Open or create a disk-based KVStore.
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.

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.KVStore open(java.io.File path,
                                                             M metadata,
                                                             SparkConf conf,
                                                             scala.reflect.ClassTag<M> evidence$1)

Open or create a disk-based KVStore.

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.

conf - SparkConf use to get HYBRID_STORE_DISK_BACKEND

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.

org$apache$spark$internal$Logging$$log_

public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

org$apache$spark$internal$Logging$$log__$eq

public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)