org.apache.beam.sdk.fn.data

Class WeightedList<T>

java.lang.Object

org.apache.beam.sdk.fn.data.WeightedList<T>

public class WeightedList<T>
extends java.lang.Object

Facade for a List that keeps track of weight, for cache limit reasons.

Constructor Summary

Constructors

Constructor and Description
WeightedList(java.util.List<T> backing, long weight)

Method Summary

Modifier and Type	Method and Description
void	accumulateWeight(long weight)
void	add(T element, long weight)
void	addAll(java.util.List<T> values, long weight)
void	addAll(WeightedList<T> values)
java.util.List<T>	getBacking()
long	getWeight()
boolean	isEmpty()
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

WeightedList

public WeightedList(java.util.List<T> backing,
                    long weight)

Method Detail

getBacking

public java.util.List<T> getBacking()

size

public int size()

isEmpty

public boolean isEmpty()

getWeight

public long getWeight()

add

public void add(T element,
                long weight)

addAll

public void addAll(WeightedList<T> values)

addAll

public void addAll(java.util.List<T> values,
                   long weight)

accumulateWeight

public void accumulateWeight(long weight)