org.corfudb.runtime.view.stream

Class AddressMapStreamView

java.lang.Object

org.corfudb.runtime.view.stream.AbstractContextStreamView<org.corfudb.runtime.view.stream.AbstractQueuedStreamView.QueuedStreamContext>

org.corfudb.runtime.view.stream.AbstractQueuedStreamView

org.corfudb.runtime.view.stream.AddressMapStreamView

All Implemented Interfaces:

AutoCloseable, Iterator<ILogData>, IStreamView

public class AddressMapStreamView
extends AbstractQueuedStreamView

A view of a stream implemented with address maps. A stream's address space is discovered by requesting to the sequencer, the map of all addresses belonging to this stream. Notice that, unlike the BackpointerStreamView, addresses are discovered in a single call to the sequencer, therefore, entries are not read in advance. For this reason, when iterating over the stream (getNextEntry) we perform batch reads, which significantly reduces the number of RPCs to Log Units, as opposed to reading one entry at a time. Also, single stepping in the presence of holes is no longer a need as address space is determined by the map provided by the sequencer. Created by annym on 04/25/19.

Nested Class Summary

Nested classes/interfaces inherited from class org.corfudb.runtime.view.stream.AbstractQueuedStreamView

AbstractQueuedStreamView.BackpointerOp

Nested classes/interfaces inherited from interface org.corfudb.runtime.view.stream.IStreamView

IStreamView.SearchDirection

Constructor Summary

Constructors

Constructor and Description
AddressMapStreamView(CorfuRuntime runtime, UUID streamId)
AddressMapStreamView(CorfuRuntime runtime, UUID streamId, StreamOptions options) Create a new address map stream view.

Method Summary

Modifier and Type	Method and Description
protected boolean	discoverAddressSpace(UUID streamId, NavigableSet<Long> queue, long startAddress, long stopAddress, Function<ILogData,AbstractQueuedStreamView.BackpointerOp> filter, boolean checkpoint, long maxGlobal) Retrieve this stream's address map, i.e., a map of all addresses corresponding to this stream between (stop address, start address] and return a boolean indicating if addresses were found in this range.
long	getTotalUpdates() Get total number of updates registered to this stream.
protected ILogData	removeFromQueue(NavigableSet<Long> queue) Remove next entry from the queue.

Methods inherited from class org.corfudb.runtime.view.stream.AbstractQueuedStreamView

addToResolvedQueue, append, close, current, fillFromResolved, fillReadQueue, find, gc, getCurrentGlobalPosition, getHasNext, getNextEntries, getNextEntry, previous, read, read, readAll, readRange, resolveCheckpoint

Methods inherited from class org.corfudb.runtime.view.stream.AbstractContextStreamView

doesEntryUpdateContext, getCurrentContext, hasNext, nextUpTo, popContext, processEntryForContext, pushNewContext, remainingUpTo, reset, seek, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.corfudb.runtime.view.stream.IStreamView

append, getId, next, remaining, spliterator, spliteratorUpTo, stream, streamUpTo

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

AddressMapStreamView

public AddressMapStreamView(CorfuRuntime runtime,
                            UUID streamId,
                            @Nonnull
                            StreamOptions options)

Create a new address map stream view.

Parameters:

runtime - The runtime to use for accessing the log.

streamId - The ID of the stream to view.

AddressMapStreamView

public AddressMapStreamView(CorfuRuntime runtime,
                            UUID streamId)

Method Detail

removeFromQueue

protected ILogData removeFromQueue(NavigableSet<Long> queue)

Description copied from class: AbstractQueuedStreamView

Remove next entry from the queue.

Specified by:

removeFromQueue in class AbstractQueuedStreamView

Parameters:

queue - queue of entries.

Returns:

next available entry. or null if there are no more entries or remaining entries are not part of this stream.

discoverAddressSpace

protected boolean discoverAddressSpace(UUID streamId,
                                       NavigableSet<Long> queue,
                                       long startAddress,
                                       long stopAddress,
                                       Function<ILogData,AbstractQueuedStreamView.BackpointerOp> filter,
                                       boolean checkpoint,
                                       long maxGlobal)

Retrieve this stream's address map, i.e., a map of all addresses corresponding to this stream between (stop address, start address] and return a boolean indicating if addresses were found in this range.

Specified by:

discoverAddressSpace in class AbstractQueuedStreamView

Parameters:

streamId - stream's ID, it is required because this same method can be used for discovering addresses from the checkpoint stream.

queue - queue to insert discovered addresses in the given range

startAddress - range start address (inclusive)

stopAddress - range end address (exclusive and lower than start address)

filter - function to filter entries

checkpoint - boolean indicating if it is a checkpoint stream

maxGlobal - maximum Address until which we want to sync (is not necessarily equal to start address)

Returns:

getTotalUpdates

public long getTotalUpdates()

Description copied from interface: IStreamView

Get total number of updates registered to this stream.

Returns:

total number of updates belonging to this stream.