org.apache.flink.runtime.util

Class EvictingBoundedList<T>

java.lang.Object

org.apache.flink.runtime.util.EvictingBoundedList<T>

Type Parameters:

T - type of the list elements

All Implemented Interfaces:

Serializable, Iterable<T>

public class EvictingBoundedList<T>
extends Object
implements Iterable<T>, Serializable

This class implements a list (array based) that is physically bounded in maximum size, but can virtually grow beyond the bounded size. When the list grows beyond the size bound, elements are dropped from the head of the list (FIFO order). If dropped elements are accessed, a default element is returned instead.

The list by itself is serializable, but a full list can only be serialized if the values are also serializable.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EvictingBoundedList(EvictingBoundedList<T> other)
EvictingBoundedList(int sizeLimit)
EvictingBoundedList(int sizeLimit, T defaultElement)

Method Summary

Modifier and Type	Method and Description
boolean	add(T t)
void	clear()
T	get(int index)
T	getDefaultElement()
int	getSizeLimit()
boolean	isEmpty()
Iterator<T>	iterator()
T	set(int index, T element)
int	size()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

EvictingBoundedList

public EvictingBoundedList(int sizeLimit)

EvictingBoundedList

public EvictingBoundedList(EvictingBoundedList<T> other)

EvictingBoundedList

public EvictingBoundedList(int sizeLimit,
                           T defaultElement)

Method Detail

size

public int size()

isEmpty

public boolean isEmpty()

add

public boolean add(T t)

clear

public void clear()

get

public T get(int index)

getSizeLimit

public int getSizeLimit()

set

public T set(int index,
             T element)

getDefaultElement

public T getDefaultElement()

iterator

@Nonnull
public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>