org.corfudb.runtime.view.stream

Class BackpointerStreamView

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.BackpointerStreamView

All Implemented Interfaces:

AutoCloseable, Iterator<ILogData>, IStreamView

public class BackpointerStreamView
extends AbstractQueuedStreamView

A view of a stream implemented with backpointers.

In this implementation, all addresses are global (log) addresses.

All method calls of this class are thread-safe.

Created by mwei on 12/11/15.

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
BackpointerStreamView(CorfuRuntime runtime, UUID streamId)
BackpointerStreamView(CorfuRuntime runtime, UUID streamId, StreamOptions options) Create a new backpointer 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) Defines the strategy to discover addresses belonging to this stream.
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

BackpointerStreamView

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

Create a new backpointer stream view.

Parameters:

runtime - The runtime to use for accessing the log.

streamId - The ID of the stream to view.

BackpointerStreamView

public BackpointerStreamView(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.

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.

discoverAddressSpace

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

Description copied from class: AbstractQueuedStreamView

Defines the strategy to discover addresses belonging to this stream. We currently support two mechanisms: - Following backpointers (@see org.corfudb.runtime.view.stream.BackpointerStreamView) - Requesting the sequencer for the complete address map of a stream. (@see org.corfudb.runtime.view.stream.AddressMapStreamView)

Specified by:

discoverAddressSpace in class AbstractQueuedStreamView

Parameters:

streamId - stream unique identifier.

queue - queue to fill up.

startAddress - read start address (inclusive)

stopAddress - read stop address (exclusive)

filter - filter to apply to data

checkpoint - true if checkpoint discovery, false otherwise.

maxGlobal - max address to resolve discovery.

Returns:

true if addresses were discovered, false, otherwise.