com.bigdata.blueprints

Class BigdataGraphEmbedded

java.lang.Object

com.bigdata.blueprints.BigdataGraph

com.bigdata.blueprints.BigdataGraphEmbedded

All Implemented Interfaces:

IChangeLog, com.tinkerpop.blueprints.Graph, com.tinkerpop.blueprints.TransactionalGraph

public class BigdataGraphEmbedded
extends BigdataGraph
implements com.tinkerpop.blueprints.TransactionalGraph, IChangeLog

This is the most basic possible implementation of the Blueprints Graph API. It wraps an embedded BigdataSailRepository and holds open an unisolated connection to the database for the lifespan of the Graph (until shutdown() is called.

Author:

mikepersonick

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BigdataGraphEmbedded.BigdataReadOnlyGraph
static interface	BigdataGraphEmbedded.Options

Nested classes/interfaces inherited from class com.bigdata.blueprints.BigdataGraph

BigdataGraph.EdgeIterable, BigdataGraph.FusedIterable<T>, BigdataGraph.VertexIterable, BigdataGraph.WrappedResult<E>

Nested classes/interfaces inherited from interface com.tinkerpop.blueprints.TransactionalGraph

com.tinkerpop.blueprints.TransactionalGraph.Conclusion

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	autocommitOnShutdown
protected static com.tinkerpop.blueprints.Features	FEATURES
protected BigdataSailRepository	repo

Fields inherited from class com.bigdata.blueprints.BigdataGraph

EDGE, factory, LABEL, laxProperties, maxQueryTime, SPARQL_LOG_MAX, TYPE, VERTEX

Constructor Summary

Constructors

Constructor and Description
BigdataGraphEmbedded(BigdataSail sail) Create a Blueprints wrapper around a BigdataSail instance.
BigdataGraphEmbedded(BigdataSail sail, BlueprintsValueFactory factory) Create a Blueprints wrapper around a BigdataSail instance with a non-standard BlueprintsValueFactory implementation.
BigdataGraphEmbedded(BigdataSail sail, BlueprintsValueFactory factory, Properties props) Create a Blueprints wrapper around a BigdataSail instance with a non-standard BlueprintsValueFactory implementation.
BigdataGraphEmbedded(BigdataSailRepository repo) Create a Blueprints wrapper around a BigdataSailRepository instance.
BigdataGraphEmbedded(BigdataSailRepository repo, BlueprintsValueFactory factory, Properties props) Create a Blueprints wrapper around a BigdataSailRepository instance with a non-standard BlueprintsValueFactory implementation.

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(BigdataGraphListener listener)
void	cancel(RunningQuery rQuery) Kill a running query specified by the RunningQuery object.
void	cancel(String uuid) Kill a running query specified by the UUID String.
void	cancel(UUID queryId) Kill a running query specified by the UUID.
void	changeEvent(IChangeRecord record) Changed events coming from bigdata.
void	close() Close any open resources.
void	commit()
BigdataSailRepositoryConnection	cxn() Different implementations will return different types of connections depending on the mode (client/server, embedded, read-only, etc.)
StringBuilder	dumpStore()
com.tinkerpop.blueprints.Features	getFeatures()
RunningQuery	getQueryByExternalId(String extQueryId) Return the RunningQuery for a currently executing SPARQL QUERY or UPDATE request.
RunningQuery	getQueryById(UUID queryUuid) Return the RunningQuery for a currently executing SPARQL QUERY or UPDATE request.
protected QueryEngine	getQueryEngine()
BigdataGraphEmbedded.BigdataReadOnlyGraph	getReadOnlyView()
BigdataSailRepository	getRepository()
Collection<RunningQuery>	getRunningQueries() Return a Collection of running queries
protected boolean	isQueryCancelled(UUID queryId) Helper method to determine if a query was cancelled.
boolean	isReadOnly() Is this a read-only view of the graph?
protected List<IChangeRecord>	materialize(List<IChangeRecord> records) Materialize a batch of change records.
protected void	notify(IChangeRecord record) Turn a change record into a graph edit and notify the graph listeners.
protected void	notifyRemoves() Materialize and notify listeners of the remove events.
void	removeListener(BigdataGraphListener listener)
void	rollback()
String	runningQueriesToString()
protected UUID	setQueryId(ASTContainer astContainer, UUID queryUuid) Determines the UUID which will be associated with the IRunningQuery.
protected UUID	setupQuery(BigdataSailRepositoryConnection cxn, ASTContainer astContainer, QueryType queryType, String extId) Note: This is also responsible for noticing the time at which the query begins to execute and storing the RunningQuery in the m_queries map.
void	shutdown()
void	stopTransaction(com.tinkerpop.blueprints.TransactionalGraph.Conclusion arg0) Deprecated.
protected void	tearDownQuery(UUID queryId) Remove the query from the internal queues.
protected BigdataGraphEdit	toGraphEdit(IChangeRecord record) Turn a bigdata change record into a graph edit.
void	transactionAborted() Notification of transaction aborted.
void	transactionBegin() Notification of transaction beginning.
void	transactionCommited(long commitTime) Notification of transaction committed.
void	transactionPrepare() Notification of transaction preparing for commit.

Methods inherited from class com.bigdata.blueprints.BigdataGraph

addEdge, addEdge, addEdge, addVertex, ask, ask, convert, finalizeQuery, fuse, getEdge, getEdges, getEdges, getElements, getProperty, getProperty, getProperty, getPropertyKeys, getValueFactory, getVertex, getVertices, getVertices, history, history, loadGraphML, project, project, query, removeEdge, removeProperty, removeProperty, removeVertex, select, select, setMaxQueryTime, setProperty, setProperty, toGraphAtom, toGraphAtom, toLiterals, toString, update, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tinkerpop.blueprints.Graph

addEdge, addVertex, getEdge, getEdges, getEdges, getVertex, getVertices, getVertices, query, removeEdge, removeVertex

Field Detail

repo

protected final BigdataSailRepository repo

autocommitOnShutdown

protected final boolean autocommitOnShutdown

FEATURES

protected static final com.tinkerpop.blueprints.Features FEATURES

Constructor Detail

BigdataGraphEmbedded

public BigdataGraphEmbedded(BigdataSail sail)

Create a Blueprints wrapper around a BigdataSail instance.

BigdataGraphEmbedded

public BigdataGraphEmbedded(BigdataSail sail,
                    BlueprintsValueFactory factory)

Create a Blueprints wrapper around a BigdataSail instance with a non-standard BlueprintsValueFactory implementation.

BigdataGraphEmbedded

public BigdataGraphEmbedded(BigdataSail sail,
                    BlueprintsValueFactory factory,
                    Properties props)

Create a Blueprints wrapper around a BigdataSail instance with a non-standard BlueprintsValueFactory implementation.

BigdataGraphEmbedded

public BigdataGraphEmbedded(BigdataSailRepository repo)

Create a Blueprints wrapper around a BigdataSailRepository instance.

BigdataGraphEmbedded

public BigdataGraphEmbedded(BigdataSailRepository repo,
                    BlueprintsValueFactory factory,
                    Properties props)

Create a Blueprints wrapper around a BigdataSailRepository instance with a non-standard BlueprintsValueFactory implementation.

Method Detail

getRepository

public BigdataSailRepository getRepository()

cxn

public BigdataSailRepositoryConnection cxn()
                                    throws Exception

Description copied from class: BigdataGraph

Different implementations will return different types of connections depending on the mode (client/server, embedded, read-only, etc.)

Specified by:

cxn in class BigdataGraph

Throws:

Exception

getReadOnlyView

public BigdataGraphEmbedded.BigdataReadOnlyGraph getReadOnlyView()
                                                          throws Exception

Throws:

Exception

commit

public void commit()

Specified by:

commit in interface com.tinkerpop.blueprints.TransactionalGraph

rollback

public void rollback()

Specified by:

rollback in interface com.tinkerpop.blueprints.TransactionalGraph

shutdown

public void shutdown()

Specified by:

shutdown in interface com.tinkerpop.blueprints.Graph

Specified by:

shutdown in interface com.tinkerpop.blueprints.TransactionalGraph

stopTransaction

@Deprecated
public void stopTransaction(com.tinkerpop.blueprints.TransactionalGraph.Conclusion arg0)

Deprecated.

Specified by:

stopTransaction in interface com.tinkerpop.blueprints.TransactionalGraph

dumpStore

public StringBuilder dumpStore()
                        throws Exception

Throws:

Exception

getFeatures

public com.tinkerpop.blueprints.Features getFeatures()

Specified by:

getFeatures in interface com.tinkerpop.blueprints.Graph

Overrides:

getFeatures in class BigdataGraph

addListener

public void addListener(BigdataGraphListener listener)

removeListener

public void removeListener(BigdataGraphListener listener)

changeEvent

public void changeEvent(IChangeRecord record)

Changed events coming from bigdata.

Specified by:

changeEvent in interface IChangeLog

Parameters:

record - the IChangeRecord

notify

protected void notify(IChangeRecord record)

Turn a change record into a graph edit and notify the graph listeners.

Parameters:

record - Bigdata change record.

toGraphEdit

protected BigdataGraphEdit toGraphEdit(IChangeRecord record)

Turn a bigdata change record into a graph edit.

Parameters:

record - Bigdata change record

Returns:

graph edit

materialize

protected List<IChangeRecord> materialize(List<IChangeRecord> records)

Materialize a batch of change records.

Parameters:

records - Bigdata change records

Returns:

Same records with materialized values

transactionBegin

public void transactionBegin()

Notification of transaction beginning.

Specified by:

transactionBegin in interface IChangeLog

transactionPrepare

public void transactionPrepare()

Notification of transaction preparing for commit.

Specified by:

transactionPrepare in interface IChangeLog

transactionCommited

public void transactionCommited(long commitTime)

Notification of transaction committed.

Specified by:

transactionCommited in interface IChangeLog

Parameters:

commitTime - The timestamp associated with the commit point.

transactionAborted

public void transactionAborted()

Notification of transaction aborted.

Specified by:

transactionAborted in interface IChangeLog

close

public void close()

Description copied from interface: IChangeLog

Close any open resources.

Specified by:

close in interface IChangeLog

notifyRemoves

protected void notifyRemoves()

Materialize and notify listeners of the remove events.

getQueryEngine

protected QueryEngine getQueryEngine()

setupQuery

protected UUID setupQuery(BigdataSailRepositoryConnection cxn,
              ASTContainer astContainer,
              QueryType queryType,
              String extId)

Note: This is also responsible for noticing the time at which the query begins to execute and storing the RunningQuery in the m_queries map.

Specified by:

setupQuery in class BigdataGraph

Parameters:

The - connection.

Returns:

setQueryId

protected UUID setQueryId(ASTContainer astContainer,
              UUID queryUuid)

Determines the UUID which will be associated with the IRunningQuery. If QueryHints.QUERYID has already been used by the application to specify the UUID then that UUID is noted. Otherwise, a random UUID is generated and assigned to the query by binding it on the query hints.

Note: The ability to provide metadata from the ASTContainer in the StatusServlet or the "EXPLAIN" page depends on the ability to cross walk the queryIds as established by this method.

Parameters:

query - The query.

queryUuid -

Returns:

The UUID which will be associated with the IRunningQuery and never null.

getQueryById

public RunningQuery getQueryById(UUID queryUuid)

Description copied from class: BigdataGraph

Return the RunningQuery for a currently executing SPARQL QUERY or UPDATE request.

Specified by:

getQueryById in class BigdataGraph

Parameters:

queryUuid - The UUID for the request.

Returns:

The RunningQuery iff it was found.

getQueryByExternalId

public RunningQuery getQueryByExternalId(String extQueryId)

Description copied from class: BigdataGraph

Return the RunningQuery for a currently executing SPARQL QUERY or UPDATE request.

Specified by:

getQueryByExternalId in class BigdataGraph

Returns:

The RunningQuery iff it was found.

tearDownQuery

protected void tearDownQuery(UUID queryId)

Remove the query from the internal queues.

Specified by:

tearDownQuery in class BigdataGraph

isQueryCancelled

protected boolean isQueryCancelled(UUID queryId)

Helper method to determine if a query was cancelled.

Specified by:

isQueryCancelled in class BigdataGraph

Parameters:

queryId -

Returns:

runningQueriesToString

public String runningQueriesToString()

getRunningQueries

public Collection<RunningQuery> getRunningQueries()

Description copied from class: BigdataGraph

Return a Collection of running queries

Specified by:

getRunningQueries in class BigdataGraph

Returns:

cancel

public void cancel(UUID queryId)

Description copied from class: BigdataGraph

Kill a running query specified by the UUID. Do nothing if the query has completed.

Specified by:

cancel in class BigdataGraph

cancel

public void cancel(String uuid)

Description copied from class: BigdataGraph

Kill a running query specified by the UUID String. Do nothing if the query has completed.

Specified by:

cancel in class BigdataGraph

cancel

public void cancel(RunningQuery rQuery)

Description copied from class: BigdataGraph

Kill a running query specified by the RunningQuery object. Do nothing if the query has completed.

Specified by:

cancel in class BigdataGraph

isReadOnly

public boolean isReadOnly()

Description copied from class: BigdataGraph

Is this a read-only view of the graph?

Specified by:

isReadOnly in class BigdataGraph