org.apache.spark.graphx.util.collection

Class GraphXPrimitiveKeyOpenHashMap<K,V>

Object

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V>

All Implemented Interfaces:

java.io.Serializable, scala.collection.generic.FilterMonadic<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>, scala.collection.generic.GenericTraversableTemplate<scala.Tuple2<K,V>,scala.collection.Iterable>, scala.collection.generic.HasNewBuilder<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>, scala.collection.GenIterable<scala.Tuple2<K,V>>, scala.collection.GenIterableLike<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>, scala.collection.GenTraversable<scala.Tuple2<K,V>>, scala.collection.GenTraversableLike<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>, scala.collection.GenTraversableOnce<scala.Tuple2<K,V>>, scala.collection.Iterable<scala.Tuple2<K,V>>, scala.collection.IterableLike<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>, scala.collection.Parallelizable<scala.Tuple2<K,V>,scala.collection.parallel.ParIterable<scala.Tuple2<K,V>>>, scala.collection.Traversable<scala.Tuple2<K,V>>, scala.collection.TraversableLike<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>, scala.collection.TraversableOnce<scala.Tuple2<K,V>>, scala.Equals

public class GraphXPrimitiveKeyOpenHashMap<K,V>
extends Object
implements scala.collection.Iterable<scala.Tuple2<K,V>>, scala.Serializable

A fast hash map implementation for primitive, non-null keys. This hash map supports insertions and updates, but not deletions. This map is about an order of magnitude faster than java.util.HashMap, while using much less space overhead.

Under the hood, it uses our OpenHashSet implementation.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface scala.collection.TraversableLike

scala.collection.TraversableLike.WithFilter

Constructor Summary

Constructors

Constructor and Description
GraphXPrimitiveKeyOpenHashMap(scala.reflect.ClassTag<K> evidence$5, scala.reflect.ClassTag<V> evidence$6) Allocate an OpenHashMap with a default initial capacity, providing a true no-argument constructor.
GraphXPrimitiveKeyOpenHashMap(int initialCapacity, scala.reflect.ClassTag<K> evidence$3, scala.reflect.ClassTag<V> evidence$4) Allocate an OpenHashMap with a fixed initial capacity
GraphXPrimitiveKeyOpenHashMap(org.apache.spark.util.collection.OpenHashSet<K> keySet, scala.reflect.ClassTag<K> evidence$7, scala.reflect.ClassTag<V> evidence$8) Allocate an OpenHashMap with a fixed initial capacity
GraphXPrimitiveKeyOpenHashMap(org.apache.spark.util.collection.OpenHashSet<K> keySet, Object _values, scala.reflect.ClassTag<K> evidence$1, scala.reflect.ClassTag<V> evidence$2)

Method Summary

Methods

Modifier and Type	Method and Description
Object	_values()
V	apply(K k) Get the value for a given key
V	changeValue(K k, scala.Function0<V> defaultValue, scala.Function1<V,V> mergeValue) If the key doesn't exist yet in the hash map, set its value to defaultValue; otherwise, set its value to mergeValue(oldValue).
V	getOrElse(K k, V elseValue) Get the value for a given key, or returns elseValue if it doesn't exist.
Object	iterator()
org.apache.spark.util.collection.OpenHashSet<K>	keySet()
void	setMerge(K k, V v, scala.Function2<V,V,V> mergeF) Set the value for a key
int	size()
void	update(K k, V v) Set the value for a key

Methods inherited from class Object

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

Methods inherited from interface scala.collection.Iterable

companion, seq

Methods inherited from interface scala.collection.IterableLike

canEqual, copyToArray, drop, dropRight, exists, find, foldRight, forall, foreach, grouped, head, isEmpty, reduceRight, sameElements, slice, sliding, sliding, take, takeRight, takeWhile, thisCollection, toCollection, toIterable, toIterator, toStream, view, view, zip, zipAll, zipWithIndex

Methods inherited from interface scala.Equals

equals

Methods inherited from interface scala.collection.TraversableLike

$plus$plus, $plus$plus$colon, $plus$plus$colon, collect, dropWhile, filter, filterNot, flatMap, groupBy, hasDefiniteSize, headOption, init, inits, isTraversableAgain, last, lastOption, map, parCombiner, partition, repr, scan, scanLeft, scanRight, sliceWithKnownBound, sliceWithKnownDelta, span, splitAt, stringPrefix, tail, tails, to, toString, toTraversable, withFilter

Methods inherited from interface scala.collection.GenTraversableOnce

$div$colon$bslash

Constructor Detail

GraphXPrimitiveKeyOpenHashMap

public GraphXPrimitiveKeyOpenHashMap(org.apache.spark.util.collection.OpenHashSet<K> keySet,
                             Object _values,
                             scala.reflect.ClassTag<K> evidence$1,
                             scala.reflect.ClassTag<V> evidence$2)

GraphXPrimitiveKeyOpenHashMap

public GraphXPrimitiveKeyOpenHashMap(int initialCapacity,
                             scala.reflect.ClassTag<K> evidence$3,
                             scala.reflect.ClassTag<V> evidence$4)

Allocate an OpenHashMap with a fixed initial capacity

GraphXPrimitiveKeyOpenHashMap

public GraphXPrimitiveKeyOpenHashMap(scala.reflect.ClassTag<K> evidence$5,
                             scala.reflect.ClassTag<V> evidence$6)

Allocate an OpenHashMap with a default initial capacity, providing a true no-argument constructor.

GraphXPrimitiveKeyOpenHashMap

public GraphXPrimitiveKeyOpenHashMap(org.apache.spark.util.collection.OpenHashSet<K> keySet,
                             scala.reflect.ClassTag<K> evidence$7,
                             scala.reflect.ClassTag<V> evidence$8)

Allocate an OpenHashMap with a fixed initial capacity

Method Detail

keySet

public org.apache.spark.util.collection.OpenHashSet<K> keySet()

_values

public Object _values()

size

public int size()

Specified by:

size in interface scala.collection.GenTraversableLike<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>

Specified by:

size in interface scala.collection.GenTraversableOnce<scala.Tuple2<K,V>>

Specified by:

size in interface scala.collection.TraversableOnce<scala.Tuple2<K,V>>

apply

public V apply(K k)

Get the value for a given key

getOrElse

public V getOrElse(K k,
          V elseValue)

Get the value for a given key, or returns elseValue if it doesn't exist.

update

public void update(K k,
          V v)

Set the value for a key

setMerge

public void setMerge(K k,
            V v,
            scala.Function2<V,V,V> mergeF)

Set the value for a key

changeValue

public V changeValue(K k,
            scala.Function0<V> defaultValue,
            scala.Function1<V,V> mergeValue)

If the key doesn't exist yet in the hash map, set its value to defaultValue; otherwise, set its value to mergeValue(oldValue).

Returns:

the newly updated value.

iterator

public Object iterator()

Specified by:

iterator in interface scala.collection.GenIterableLike<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>

Specified by:

iterator in interface scala.collection.IterableLike<scala.Tuple2<K,V>,scala.collection.Iterable<scala.Tuple2<K,V>>>