org.corfudb.runtime.view

Class ObjectsView

java.lang.Object

org.corfudb.runtime.view.AbstractView

org.corfudb.runtime.view.ObjectsView

public class ObjectsView
extends AbstractView

A view of the objects inside a Corfu instance. Created by mwei on 1/7/16.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ObjectsView.ObjectID<T>

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 UUID	TRANSACTION_STREAM_ID The Transaction stream is used to log/write successful transactions from different clients.

Constructor Summary

Constructors

Constructor and Description
ObjectsView(CorfuRuntime runtime)

Method Summary

Modifier and Type	Method and Description
ObjectBuilder<?>	build() Return an object builder which builds a new object.
void	gc(long trimMark) Run garbage collection on all opened objects.
void	TXAbort() Aborts a transaction on the current thread.
boolean	TXActive() Query whether a transaction is currently running.
void	TXBegin() Begins a transaction on the current thread.
TransactionBuilder	TXBuild() Builds a new transaction using the transaction builder.
long	TXEnd() End a transaction on the current thread.

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

TRANSACTION_STREAM_ID

public static UUID TRANSACTION_STREAM_ID

The Transaction stream is used to log/write successful transactions from different clients. Transaction data and meta data can be obtained by reading this stream.

Constructor Detail

ObjectsView

public ObjectsView(@Nonnull
                   CorfuRuntime runtime)

Method Detail

build

public ObjectBuilder<?> build()

Return an object builder which builds a new object.

Returns:

An object builder to open an object with.

TXBegin

public void TXBegin()

Begins a transaction on the current thread. Automatically selects the correct transaction strategy. Modifications to objects will not be visible to other threads or clients until TXEnd is called.

TXBuild

public TransactionBuilder TXBuild()

Builds a new transaction using the transaction builder.

Returns:

A transaction builder to build a transaction with.

TXAbort

public void TXAbort()

Aborts a transaction on the current thread. Modifications to objects in the current transactional context will be discarded.

TXActive

public boolean TXActive()

Query whether a transaction is currently running.

Returns:

True, if called within a transactional context, False, otherwise.

TXEnd

public long TXEnd()
           throws TransactionAbortedException

End a transaction on the current thread.

Returns:

The address of the transaction, if it commits.

Throws:

TransactionAbortedException - If the transaction could not be executed successfully.

gc

public void gc(long trimMark)

Run garbage collection on all opened objects. Note that objects open with the NO_CACHE options will not be gc'd