com.blazegraph.gremlin.embedded

Class BlazeGraphEmbedded.BlazeTransaction

java.lang.Object

org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction

org.apache.tinkerpop.gremlin.structure.util.AbstractThreadLocalTransaction

com.blazegraph.gremlin.embedded.BlazeGraphEmbedded.BlazeTransaction

All Implemented Interfaces:

AutoCloseable, org.apache.tinkerpop.gremlin.structure.Transaction

Enclosing class:

BlazeGraphEmbedded

public class BlazeGraphEmbedded.BlazeTransaction
extends org.apache.tinkerpop.gremlin.structure.util.AbstractThreadLocalTransaction

Tinkerpop3 Transaction object. Wraps access to the unsiolated SAIL connection in a thread local. Access will be re-entrant, but the unisolated connection cannot be shared across multiple threads. Threads attempting to access the unisolated SAIL connection (via tx().open(), which happens automatically on any write or read operation) will be blocked by the connection owner thread until that thread closes it (via tx().close(), which happens automatically on any commit or rollback operation).

Author:

mikepersonick

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction

org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction.TransactionException

Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.structure.Transaction

org.apache.tinkerpop.gremlin.structure.Transaction.CLOSE_BEHAVIOR, org.apache.tinkerpop.gremlin.structure.Transaction.Exceptions, org.apache.tinkerpop.gremlin.structure.Transaction.READ_WRITE_BEHAVIOR, org.apache.tinkerpop.gremlin.structure.Transaction.Status, org.apache.tinkerpop.gremlin.structure.Transaction.Workload<R>

Field Summary

Fields inherited from class org.apache.tinkerpop.gremlin.structure.util.AbstractThreadLocalTransaction

closeConsumerInternal, readWriteConsumerInternal, transactionListeners

Method Summary

Modifier and Type	Method and Description
com.bigdata.rdf.sail.BigdataSailRepositoryConnection	cxn() Direct access to the unisolated connection.
protected void	doClose() Close the unisolated connection (if open), releasing it for use by other threads.
protected void	doCommit() Commit and close the unisolated connection (if open).
protected void	doOpen() Grab the unisolated SAIL connection and attach the ChangeLogTransformer to it.
protected void	doRollback() Rollback and close the unisolated connection (if open).
void	flush() Flush the statement buffers to the indices without committing.
boolean	isOpen() True if this thread has the unisolated connection open.

Methods inherited from class org.apache.tinkerpop.gremlin.structure.util.AbstractThreadLocalTransaction

addTransactionListener, clearTransactionListeners, doReadWrite, fireOnCommit, fireOnRollback, onClose, onReadWrite, removeTransactionListener

Methods inherited from class org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction

close, commit, createThreadedTx, open, readWrite, rollback, submit

Methods inherited from class java.lang.Object

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

Method Detail

isOpen

public boolean isOpen()

True if this thread has the unisolated connection open.

doOpen

protected void doOpen()

Grab the unisolated SAIL connection and attach the ChangeLogTransformer to it. This operation will block if the unisolated connection is being held open by another thread.

Specified by:

doOpen in class org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction

doCommit

protected void doCommit()
                 throws org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction.TransactionException

Commit and close the unisolated connection (if open).

Specified by:

doCommit in class org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction

Throws:

org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction.TransactionException

doRollback

protected void doRollback()
                   throws org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction.TransactionException

Rollback and close the unisolated connection (if open).

Specified by:

doRollback in class org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction

Throws:

org.apache.tinkerpop.gremlin.structure.util.AbstractTransaction.TransactionException

doClose

protected void doClose()

Close the unisolated connection (if open), releasing it for use by other threads.

Overrides:

doClose in class org.apache.tinkerpop.gremlin.structure.util.AbstractThreadLocalTransaction

cxn

public com.bigdata.rdf.sail.BigdataSailRepositoryConnection cxn()

Direct access to the unisolated connection. May return null if the connection has not been opened yet by this thread.

Returns:

unisolated BigdataSailRepositoryConnection

flush

public void flush()

Flush the statement buffers to the indices without committing.