org.apache.giraph.types.ops.collections.array

Class WDoubleArrayList

java.lang.Object

java.util.AbstractCollection<Double>

it.unimi.dsi.fastutil.doubles.AbstractDoubleCollection

it.unimi.dsi.fastutil.doubles.AbstractDoubleList

it.unimi.dsi.fastutil.doubles.DoubleArrayList

org.apache.giraph.types.ops.collections.array.WDoubleArrayList

All Implemented Interfaces:

it.unimi.dsi.fastutil.doubles.DoubleCollection, it.unimi.dsi.fastutil.doubles.DoubleIterable, it.unimi.dsi.fastutil.doubles.DoubleList, it.unimi.dsi.fastutil.doubles.DoubleStack, it.unimi.dsi.fastutil.Stack<Double>, Serializable, Cloneable, Comparable<List<? extends Double>>, Iterable<Double>, Collection<Double>, List<Double>, RandomAccess, WArrayList<org.apache.hadoop.io.DoubleWritable>, WCollection<org.apache.hadoop.io.DoubleWritable>, WDoubleCollection, org.apache.hadoop.io.Writable

Direct Known Subclasses:

WDoubleArrayList.WReusableDoubleArrayList

public class WDoubleArrayList
extends it.unimi.dsi.fastutil.doubles.DoubleArrayList
implements WArrayList<org.apache.hadoop.io.DoubleWritable>, WDoubleCollection

Writable extension of DoubleArrayList, as well as DoubleWritable implementation of WArrayList.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WDoubleArrayList.WReusableDoubleArrayList Variant of WDoubleArrayList that doesn't reallocate smaller backing array on consecutive readFields/readElements calls, and so is suitable for reusable use.

Nested classes/interfaces inherited from class it.unimi.dsi.fastutil.doubles.AbstractDoubleList

it.unimi.dsi.fastutil.doubles.AbstractDoubleList.DoubleSubList

Field Summary

Fields inherited from class it.unimi.dsi.fastutil.doubles.DoubleArrayList

a, DEFAULT_INITIAL_CAPACITY, size

Constructor Summary

Constructors

Constructor and Description
WDoubleArrayList() Creates a new array list with DoubleArrayList.DEFAULT_INITIAL_CAPACITY capacity.
WDoubleArrayList(it.unimi.dsi.fastutil.doubles.DoubleCollection c) Creates a new array list and fills it with a given type-specific collection.
WDoubleArrayList(it.unimi.dsi.fastutil.doubles.DoubleList l) Creates a new array list and fills it with a given type-specific list.
WDoubleArrayList(int capacity) Creates a new array list with given capacity.

Method Summary

Modifier and Type	Method and Description
void	addW(org.apache.hadoop.io.DoubleWritable value) Add value to the collection
int	capacity() Capacity of currently allocated memory
void	fastForEachW(Consumer<org.apache.hadoop.io.DoubleWritable> f) Traverse all elements of the collection, calling given function on each element.
boolean	fastForEachWhileW(Predicate<org.apache.hadoop.io.DoubleWritable> f) Traverse all elements of the collection, calling given function on each element, or until predicate returns false.
ResettableIterator<org.apache.hadoop.io.DoubleWritable>	fastIteratorW() Fast iterator over collection objects, which doesn't allocate new element for each returned element, and can be iterated multiple times using reset().
ResettableIterator<org.apache.hadoop.io.DoubleWritable>	fastIteratorW(org.apache.hadoop.io.DoubleWritable iterationValue) Fast iterator over collection objects, which doesn't allocate new element for each returned element, and can be iterated multiple times using reset().
void	fillW(int from, int to, org.apache.hadoop.io.DoubleWritable value) Sets given range of elements to a specified value.
void	forEachDouble(DoubleConsumer f) Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
boolean	forEachWhileDouble(DoublePredicate f) Traverse all elements of the array list, calling given function on each element.
PrimitiveTypeOps<org.apache.hadoop.io.DoubleWritable>	getElementTypeOps() TypeOps for type of elements this object holds
void	getIntoW(int index, org.apache.hadoop.io.DoubleWritable to) Get element at given index in the array, storing it into 'to' argument
void	popIntoW(org.apache.hadoop.io.DoubleWritable to) Pop value from the end of the array, storing it into 'to' argument
void	readElements(DataInput in, int size) Read elements from DataInput stream, with passing the size instead reading it from the stream.
void	readFields(DataInput in)
static WDoubleArrayList	readNew(DataInput in) Read array list from the DataInput stream into a newly created object.
protected void	resizeArrayForRead(int size) Resize array for reading given number of elements.
void	setCapacity(int n) Forces allocated memory to hold exactly N values
void	setW(int index, org.apache.hadoop.io.DoubleWritable value) Set element at given index in the array
void	sort() Sort the array in ascending order
void	write(DataOutput out)
void	writeElements(DataOutput out) Write elements to the DataOutput stream, without the size itself.
static void	writeOrNull(WDoubleArrayList list, DataOutput out) Write a potentially null list to a DataOutput.

Methods inherited from class it.unimi.dsi.fastutil.doubles.DoubleArrayList

add, add, addAll, addAll, addElements, clear, clone, compareTo, elements, ensureCapacity, equals, getDouble, getElements, indexOf, isEmpty, lastIndexOf, listIterator, rem, removeDouble, removeElements, set, size, size, toDoubleArray, trim, trim, wrap, wrap

Methods inherited from class it.unimi.dsi.fastutil.doubles.AbstractDoubleList

add, addAll, addAll, addAll, addAll, addElements, compareTo, contains, doubleListIterator, doubleListIterator, doubleSubList, ensureIndex, ensureRestrictedIndex, equals, get, hashCode, indexOf, iterator, lastIndexOf, listIterator, peek, peekDouble, pop, popDouble, push, push, remove, remove, set, subList, top, topDouble, toString

Methods inherited from class it.unimi.dsi.fastutil.doubles.AbstractDoubleCollection

add, contains, containsAll, containsAll, doubleIterator, rem, removeAll, removeAll, retainAll, retainAll, toArray, toArray, toArray, toDoubleArray

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.giraph.types.ops.collections.array.WArrayList

size, trim

Methods inherited from interface org.apache.giraph.types.ops.collections.WCollection

clear, size

Methods inherited from interface it.unimi.dsi.fastutil.doubles.DoubleCollection

add, addAll, contains, containsAll, doubleIterator, iterator, rem, removeAll, retainAll, toArray, toArray, toDoubleArray, toDoubleArray

Methods inherited from interface java.util.Collection

add, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.List

add, contains, containsAll, removeAll, replaceAll, retainAll, sort, spliterator, toArray, toArray

Constructor Detail

WDoubleArrayList

public WDoubleArrayList()

Creates a new array list with DoubleArrayList.DEFAULT_INITIAL_CAPACITY capacity.

WDoubleArrayList

public WDoubleArrayList(int capacity)

Creates a new array list with given capacity.

Parameters:

capacity - the initial capacity of the array list (may be 0).

WDoubleArrayList

public WDoubleArrayList(it.unimi.dsi.fastutil.doubles.DoubleCollection c)

Creates a new array list and fills it with a given type-specific collection.

Parameters:

c - a type-specific collection that will be used to fill the array list.

WDoubleArrayList

public WDoubleArrayList(it.unimi.dsi.fastutil.doubles.DoubleList l)

Creates a new array list and fills it with a given type-specific list.

Parameters:

l - a type-specific list that will be used to fill the array list.

Method Detail

getElementTypeOps

public PrimitiveTypeOps<org.apache.hadoop.io.DoubleWritable> getElementTypeOps()

Description copied from interface: WCollection

TypeOps for type of elements this object holds

Specified by:

getElementTypeOps in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Returns:

TypeOps

capacity

public int capacity()

Description copied from interface: WCollection

Capacity of currently allocated memory

Specified by:

capacity in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Returns:

capacity

setCapacity

public void setCapacity(int n)

Description copied from interface: WCollection

Forces allocated memory to hold exactly N values

Specified by:

setCapacity in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Parameters:

n - new capacity

addW

public void addW(org.apache.hadoop.io.DoubleWritable value)

Description copied from interface: WCollection

Add value to the collection

Specified by:

addW in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Parameters:

value - Value

getIntoW

public void getIntoW(int index,
                     org.apache.hadoop.io.DoubleWritable to)

Description copied from interface: WArrayList

Get element at given index in the array, storing it into 'to' argument

Specified by:

getIntoW in interface WArrayList<org.apache.hadoop.io.DoubleWritable>

Parameters:

index - Index

to - Object to store value into

popIntoW

public void popIntoW(org.apache.hadoop.io.DoubleWritable to)

Description copied from interface: WArrayList

Pop value from the end of the array, storing it into 'to' argument

Specified by:

popIntoW in interface WArrayList<org.apache.hadoop.io.DoubleWritable>

Parameters:

to - Object to store value into

setW

public void setW(int index,
                 org.apache.hadoop.io.DoubleWritable value)

Description copied from interface: WArrayList

Set element at given index in the array

Specified by:

setW in interface WArrayList<org.apache.hadoop.io.DoubleWritable>

Parameters:

index - Index

value - Value

fillW

public void fillW(int from,
                  int to,
                  org.apache.hadoop.io.DoubleWritable value)

Description copied from interface: WArrayList

Sets given range of elements to a specified value.

Specified by:

fillW in interface WArrayList<org.apache.hadoop.io.DoubleWritable>

Parameters:

from - From index (inclusive)

to - To index (exclusive)

value - Value

fastIteratorW

public ResettableIterator<org.apache.hadoop.io.DoubleWritable> fastIteratorW()

Description copied from interface: WCollection

Fast iterator over collection objects, which doesn't allocate new element for each returned element, and can be iterated multiple times using reset(). Object returned by next() is only valid until next() is called again, because it is reused.

Specified by:

fastIteratorW in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Returns:

RessettableIterator

fastIteratorW

public ResettableIterator<org.apache.hadoop.io.DoubleWritable> fastIteratorW(org.apache.hadoop.io.DoubleWritable iterationValue)

Description copied from interface: WCollection

Fast iterator over collection objects, which doesn't allocate new element for each returned element, and can be iterated multiple times using reset(). Each call to next() populates passed value.

Specified by:

fastIteratorW in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Parameters:

iterationValue - Value that call to next() will populate

Returns:

RessettableIterator

fastForEachW

public void fastForEachW(Consumer<org.apache.hadoop.io.DoubleWritable> f)

Description copied from interface: WCollection

Traverse all elements of the collection, calling given function on each element. Passed values are valid only during the call to the passed function, so data needs to be consumed during the function.

Specified by:

fastForEachW in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Parameters:

f - Function to call on each element.

fastForEachWhileW

public boolean fastForEachWhileW(Predicate<org.apache.hadoop.io.DoubleWritable> f)

Description copied from interface: WCollection

Traverse all elements of the collection, calling given function on each element, or until predicate returns false. Passed values are valid only during the call to the passed function, so data needs to be consumed during the function.

Specified by:

fastForEachWhileW in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Parameters:

f - Function to call on each element.

Returns:

true if the predicate returned true for all elements, false if it returned false for some element.

forEachDouble

public void forEachDouble(DoubleConsumer f)

Traverse all elements of the array list, calling given function on each element, or until predicate returns false.

Specified by:

forEachDouble in interface WDoubleCollection

Parameters:

f - Function to call on each element.

forEachWhileDouble

public boolean forEachWhileDouble(DoublePredicate f)

Traverse all elements of the array list, calling given function on each element.

Specified by:

forEachWhileDouble in interface WDoubleCollection

Parameters:

f - Function to call on each element.

Returns:

true if the predicate returned true for all elements, false if it returned false for some element.

sort

public void sort()

Description copied from interface: WArrayList

Sort the array in ascending order

Specified by:

sort in interface WArrayList<org.apache.hadoop.io.DoubleWritable>

writeElements

public void writeElements(DataOutput out)
                   throws IOException

Description copied from interface: WCollection

Write elements to the DataOutput stream, without the size itself. Can be read back using readElements function.

Specified by:

writeElements in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Parameters:

out - Data output

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readElements

public void readElements(DataInput in,
                         int size)
                  throws IOException

Description copied from interface: WCollection

Read elements from DataInput stream, with passing the size instead reading it from the stream.

Specified by:

readElements in interface WCollection<org.apache.hadoop.io.DoubleWritable>

Parameters:

in - Data Input

size - Number of elements

Throws:

IOException

resizeArrayForRead

protected void resizeArrayForRead(int size)

Resize array for reading given number of elements.

Parameters:

size - Number of elements that will be read.

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

writeOrNull

public static void writeOrNull(WDoubleArrayList list,
                               DataOutput out)
                        throws IOException

Write a potentially null list to a DataOutput. Null list is written equivalently as an empty list. Use WritableUtils.writeIfNotNullAndObject if distinction is needed.

Parameters:

list - Array list to be written

out - Data output

Throws:

IOException

readNew

public static WDoubleArrayList readNew(DataInput in)
                                throws IOException

Read array list from the DataInput stream into a newly created object.

Parameters:

in - Data input

Returns:

New read array list object.

Throws:

IOException