org.corfudb.runtime.view.stream

Class StreamAddressSpace

java.lang.Object

org.corfudb.runtime.view.stream.StreamAddressSpace

public class StreamAddressSpace
extends Object

This class represents the space of all addresses belonging to a stream. A stream's address space is defined by: 1. The collection of all addresses that belong to this stream. 2. The trim mark (last trimmed address, i.e., an address that is no longer present and that was subsumed by a checkpoint). Created by annym on 03/06/2019

Constructor Summary

Constructors

Constructor and Description
StreamAddressSpace(long trimMark, org.roaringbitmap.longlong.Roaring64NavigableMap addressMap)

Method Summary

Modifier and Type	Method and Description
void	addAddress(long address) Add an address to this address space.
NavigableSet<Long>	copyAddressesToSet(Long maxGlobal) Copy this stream's addresses to a set, under a given boundary (inclusive).
org.roaringbitmap.longlong.Roaring64NavigableMap	getAddressesInRange(StreamAddressRange range) Get addresses in range (end, start], where start > end.
org.roaringbitmap.longlong.Roaring64NavigableMap	getAddressMap()
Long	getTail() Get tail for this stream.
long	getTrimMark()
boolean	isEmpty() Checks if this stream has addresses or not.
void	removeAddresses(List<Long> addresses) Remove addresses from the stream's address map and set the new trim mark (to the greatest of all addresses to remove).
void	setTrimMark(long trimMark)
void	trim(Long trimMark) Trim all addresses lower or equal to trimMark and set new trim mark.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamAddressSpace

public StreamAddressSpace(long trimMark,
                          org.roaringbitmap.longlong.Roaring64NavigableMap addressMap)

Method Detail

getAddressMap

public org.roaringbitmap.longlong.Roaring64NavigableMap getAddressMap()

copyAddressesToSet

public NavigableSet<Long> copyAddressesToSet(Long maxGlobal)

Copy this stream's addresses to a set, under a given boundary (inclusive).

Parameters:

maxGlobal - maximum address (inclusive upper bound)

isEmpty

public boolean isEmpty()

Checks if this stream has addresses or not.

Returns:

true, if no addresses belong to this stream; false, otherwise.

getTail

public Long getTail()

Get tail for this stream.

Returns:

last address belonging to this stream

addAddress

public void addAddress(long address)

Add an address to this address space.

Parameters:

address - address to add.

removeAddresses

public void removeAddresses(List<Long> addresses)

Remove addresses from the stream's address map and set the new trim mark (to the greatest of all addresses to remove).

trim

public void trim(Long trimMark)

Trim all addresses lower or equal to trimMark and set new trim mark.

Parameters:

trimMark - upper limit of addresses to trim

getAddressesInRange

public org.roaringbitmap.longlong.Roaring64NavigableMap getAddressesInRange(StreamAddressRange range)

Get addresses in range (end, start], where start > end.

Returns:

Bitmap with addresses in this range.

setTrimMark

public void setTrimMark(long trimMark)

getTrimMark

public long getTrimMark()