org.corfudb.runtime.view

Class StreamsView

java.lang.Object

org.corfudb.runtime.view.AbstractView

org.corfudb.runtime.view.StreamsView

public class StreamsView
extends AbstractView

Created by mwei on 12/11/15.

Nested Class Summary

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

AbstractView.LayoutFunction<V,R,A extends Throwable,B extends Throwable,C extends Throwable,D extends Throwable>

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHECKPOINT_SUFFIX Checkpoint of streams have their own stream id derived from the stream id.

Constructor Summary

Constructors

Constructor and Description
StreamsView(CorfuRuntime runtime)

Method Summary

Modifier and Type	Method and Description
long	append(Object object, TxResolutionInfo conflictInfo, CacheOption cacheOption, UUID... streamIDs) Append to multiple streams simultaneously, possibly providing information on how to resolve conflicts.
long	append(Object object, TxResolutionInfo conflictInfo, UUID... streamIDs) Append to multiple streams and caches the result.
void	gc(long trimMark) Run garbage collection on all opened streams.
IStreamView	get(UUID stream) Get a view on a stream.
IStreamView	get(UUID stream, StreamOptions options) Get a view on a stream.
IStreamView	getUnsafe(UUID stream) Since streams can also be used by higher level abstractions, some consumers implement synchronization at a higher level, so the stream implementation doesn't have to be thread-safe.
IStreamView	getUnsafe(UUID stream, StreamOptions options)

Methods inherited from class org.corfudb.runtime.view.AbstractView

getCurrentLayout, layoutHelper, layoutHelper

Methods inherited from class java.lang.Object

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

Field Detail

CHECKPOINT_SUFFIX

public static final String CHECKPOINT_SUFFIX

Checkpoint of streams have their own stream id derived from the stream id. We add the checkpoint suffix to the original stream id.

See Also:

Constant Field Values

Constructor Detail

StreamsView

public StreamsView(CorfuRuntime runtime)

Method Detail

get

public IStreamView get(UUID stream)

Get a view on a stream. The view has its own pointer to the stream.

Parameters:

stream - The UUID of the stream to get a view on.

Returns:

A view

getUnsafe

public IStreamView getUnsafe(UUID stream)

Since streams can also be used by higher level abstractions, some consumers implement synchronization at a higher level, so the stream implementation doesn't have to be thread-safe. Also, gc will not be called on unsafe streams therefore gc needs to be managed by the consumer.

Parameters:

stream - stream id

Returns:

an unsafe (not thread safe) stream implementation

get

public IStreamView get(UUID stream,
                       StreamOptions options)

Get a view on a stream. The view has its own pointer to the stream.

Parameters:

stream - The UUID of the stream to get a view on.

Returns:

A view

getUnsafe

public IStreamView getUnsafe(UUID stream,
                             StreamOptions options)

gc

public void gc(long trimMark)

Run garbage collection on all opened streams. Note that opened unsafe streams will be excluded (because its unsafe for the garbage collector thread to operate on them while being used by a different thread).

append

public long append(@Nonnull
                   Object object,
                   @Nullable
                   TxResolutionInfo conflictInfo,
                   @Nonnull
                   CacheOption cacheOption,
                   @Nonnull
                   UUID... streamIDs)

Append to multiple streams simultaneously, possibly providing information on how to resolve conflicts.

Parameters:

streamIDs - The streams to append to.

object - The object to append to each stream.

conflictInfo - Conflict information for the sequencer to check.

cacheOption - The caching mode for write/append

Returns:

The address the entry was written to.

Throws:

TransactionAbortedException - If the transaction was aborted by the sequencer.

append

public long append(@Nonnull
                   Object object,
                   @Nullable
                   TxResolutionInfo conflictInfo,
                   @Nonnull
                   UUID... streamIDs)

Append to multiple streams and caches the result.

See Also:

append(Object, TxResolutionInfo, CacheOption, UUID...)