com.bigdata.blueprints

Class BigdataGraphBulkLoad

java.lang.Object

com.bigdata.blueprints.BigdataGraph

com.bigdata.blueprints.BigdataGraphBulkLoad

All Implemented Interfaces:

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

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

Simple bulk loader that will insert graph data without any consistency checking (won't check for duplicate vertex or edge identifiers). Currently does not overwrite old property values, but we may need to change this.

Implements IChangeLog so that we can report a mutation count.

Author:

mikepersonick

Nested Class Summary

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

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

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

com.tinkerpop.blueprints.TransactionalGraph.Conclusion

Field Summary

Fields inherited from class com.bigdata.blueprints.BigdataGraph

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

Constructor Summary

Constructors

Constructor and Description
BigdataGraphBulkLoad(BigdataSailRepositoryConnection cxn)
BigdataGraphBulkLoad(BigdataSailRepositoryConnection cxn, BlueprintsValueFactory factory)

Method Summary

Methods

Modifier and Type	Method and Description
com.tinkerpop.blueprints.Edge	addEdge(Object key, com.tinkerpop.blueprints.Vertex from, com.tinkerpop.blueprints.Vertex to, String label) Add an edge.
com.tinkerpop.blueprints.Vertex	addVertex(Object key) Add a vertex.
void	cancel(RunningQuery r) Kill a running query specified by the RunningQuery object.
void	cancel(String externalQueryId) 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) Occurs when a statement add or remove is flushed to the indices (but not yet committed).
void	close() Close any open resources.
void	commit()
org.openrdf.repository.RepositoryConnection	cxn() Different implementations will return different types of connections depending on the mode (client/server, embedded, read-only, etc.)
com.tinkerpop.blueprints.Edge	getEdge(Object arg0) Lookup an edge.
Iterable<com.tinkerpop.blueprints.Edge>	getEdges() Iterate all edges.
Iterable<com.tinkerpop.blueprints.Edge>	getEdges(String arg0, Object arg1) Find edges with the supplied property value.
long	getMutationCountCurrentCommit()
long	getMutationCountLastCommit()
long	getMutationCountTotal()
RunningQuery	getQueryByExternalId(String extQueryId) Return the RunningQuery for a currently executing SPARQL QUERY or UPDATE request.
RunningQuery	getQueryById(UUID queryId2) Return the RunningQuery for a currently executing SPARQL QUERY or UPDATE request.
Collection<RunningQuery>	getRunningQueries() Return a Collection of running queries
com.tinkerpop.blueprints.Vertex	getVertex(Object key) Lookup a vertex.
Iterable<com.tinkerpop.blueprints.Vertex>	getVertices() Iterate all vertices.
Iterable<com.tinkerpop.blueprints.Vertex>	getVertices(String arg0, Object arg1) Find vertices with the supplied property value.
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?
com.tinkerpop.blueprints.GraphQuery	query() Providing an override implementation for our GraphQuery to avoid the low-performance scan and filter paradigm.
void	removeEdge(com.tinkerpop.blueprints.Edge arg0) Remove an edge and its properties.
void	removeVertex(com.tinkerpop.blueprints.Vertex arg0) Remove a vertex and its edges and properties.
void	rollback()
void	setProperty(org.openrdf.model.URI uri, org.openrdf.model.URI prop, Collection<org.openrdf.model.Literal> vals) Set a multi-value property on an edge or vertex (remove the old values first).
protected UUID	setupQuery(BigdataSailRepositoryConnection cxn, ASTContainer astContainer, QueryType queryType, String extQueryId) Embedded clients can override this to access query management capabilities.
void	shutdown()
void	stopTransaction(com.tinkerpop.blueprints.TransactionalGraph.Conclusion arg0) Deprecated.
protected void	tearDownQuery(UUID queryId) Embedded clients can override this to access query management capabilities.
void	transactionAborted() Occurs if the current SAIL transaction is aborted.
void	transactionBegin() Message issued when a new transaction will begin.
void	transactionCommited(long commitTime) Occurs when the current SAIL transaction is committed.
void	transactionPrepare() Message issued when preparing for a commit.

Methods inherited from class com.bigdata.blueprints.BigdataGraph

addEdge, addEdge, ask, ask, convert, finalizeQuery, fuse, getElements, getFeatures, getProperty, getProperty, getProperty, getPropertyKeys, getValueFactory, history, history, loadGraphML, project, project, removeProperty, removeProperty, select, select, setMaxQueryTime, 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

getFeatures

Constructor Detail

BigdataGraphBulkLoad

public BigdataGraphBulkLoad(BigdataSailRepositoryConnection cxn)

BigdataGraphBulkLoad

public BigdataGraphBulkLoad(BigdataSailRepositoryConnection cxn,
                    BlueprintsValueFactory factory)

Method Detail

cxn

public org.openrdf.repository.RepositoryConnection 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

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

getEdge

public com.tinkerpop.blueprints.Edge getEdge(Object arg0)

Description copied from class: BigdataGraph

Lookup an edge.

Specified by:

getEdge in interface com.tinkerpop.blueprints.Graph

Overrides:

getEdge in class BigdataGraph

getEdges

public Iterable<com.tinkerpop.blueprints.Edge> getEdges()

Description copied from class: BigdataGraph

Iterate all edges.

Specified by:

getEdges in interface com.tinkerpop.blueprints.Graph

Overrides:

getEdges in class BigdataGraph

getEdges

public Iterable<com.tinkerpop.blueprints.Edge> getEdges(String arg0,
                                               Object arg1)

Description copied from class: BigdataGraph

Find edges with the supplied property value. construct { ?from ?edge ?to . } where { ?edge . ?from ?edge ?to . }

Specified by:

getEdges in interface com.tinkerpop.blueprints.Graph

Overrides:

getEdges in class BigdataGraph

getVertex

public com.tinkerpop.blueprints.Vertex getVertex(Object key)

Description copied from class: BigdataGraph

Lookup a vertex.

Specified by:

getVertex in interface com.tinkerpop.blueprints.Graph

Overrides:

getVertex in class BigdataGraph

getVertices

public Iterable<com.tinkerpop.blueprints.Vertex> getVertices()

Description copied from class: BigdataGraph

Iterate all vertices.

Specified by:

getVertices in interface com.tinkerpop.blueprints.Graph

Overrides:

getVertices in class BigdataGraph

getVertices

public Iterable<com.tinkerpop.blueprints.Vertex> getVertices(String arg0,
                                                    Object arg1)

Description copied from class: BigdataGraph

Find vertices with the supplied property value.

Specified by:

getVertices in interface com.tinkerpop.blueprints.Graph

Overrides:

getVertices in class BigdataGraph

query

public com.tinkerpop.blueprints.GraphQuery query()

Description copied from class: BigdataGraph

Providing an override implementation for our GraphQuery to avoid the low-performance scan and filter paradigm. See BigdataGraphQuery.

Specified by:

query in interface com.tinkerpop.blueprints.Graph

Overrides:

query in class BigdataGraph

removeEdge

public void removeEdge(com.tinkerpop.blueprints.Edge arg0)

Description copied from class: BigdataGraph

Remove an edge and its properties.

Specified by:

removeEdge in interface com.tinkerpop.blueprints.Graph

Overrides:

removeEdge in class BigdataGraph

removeVertex

public void removeVertex(com.tinkerpop.blueprints.Vertex arg0)

Description copied from class: BigdataGraph

Remove a vertex and its edges and properties. TODO FIXME I am not fully removing dependent edges.

Specified by:

removeVertex in interface com.tinkerpop.blueprints.Graph

Overrides:

removeVertex in class BigdataGraph

setProperty

public void setProperty(org.openrdf.model.URI uri,
               org.openrdf.model.URI prop,
               Collection<org.openrdf.model.Literal> vals)

Set a multi-value property on an edge or vertex (remove the old values first).

Overrides:

setProperty in class BigdataGraph

See Also:

BigdataElement}

addVertex

public com.tinkerpop.blueprints.Vertex addVertex(Object key)

Add a vertex.

Specified by:

addVertex in interface com.tinkerpop.blueprints.Graph

Overrides:

addVertex in class BigdataGraph

addEdge

public com.tinkerpop.blueprints.Edge addEdge(Object key,
                                    com.tinkerpop.blueprints.Vertex from,
                                    com.tinkerpop.blueprints.Vertex to,
                                    String label)

Add an edge.

Specified by:

addEdge in interface com.tinkerpop.blueprints.Graph

Overrides:

addEdge in class BigdataGraph

changeEvent

public void changeEvent(IChangeRecord record)

Description copied from interface: IChangeLog

Occurs when a statement add or remove is flushed to the indices (but not yet committed).

Specified by:

changeEvent in interface IChangeLog

Parameters:

record - the IChangeRecord

transactionBegin

public void transactionBegin()

Description copied from interface: IChangeLog

Message issued when a new transaction will begin.

Specified by:

transactionBegin in interface IChangeLog

transactionPrepare

public void transactionPrepare()

Description copied from interface: IChangeLog

Message issued when preparing for a commit. The next message will be either IChangeLog.transactionCommited(long) or IChangeLog.transactionAborted().

Note: The listener will have observed all updates by the time this message is generated. Thus, this message can be used to validate post-conditions for the transaction.

Specified by:

transactionPrepare in interface IChangeLog

transactionCommited

public void transactionCommited(long commitTime)

Description copied from interface: IChangeLog

Occurs when the current SAIL transaction is committed.

Specified by:

transactionCommited in interface IChangeLog

Parameters:

commitTime - The timestamp associated with the commit point.

transactionAborted

public void transactionAborted()

Description copied from interface: IChangeLog

Occurs if the current SAIL transaction is 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

getMutationCountTotal

public long getMutationCountTotal()

getMutationCountCurrentCommit

public long getMutationCountCurrentCommit()

getMutationCountLastCommit

public long getMutationCountLastCommit()

setupQuery

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

Description copied from class: BigdataGraph

Embedded clients can override this to access query management capabilities.

Specified by:

setupQuery in class BigdataGraph

Returns:

tearDownQuery

protected void tearDownQuery(UUID queryId)

Description copied from class: BigdataGraph

Embedded clients can override this to access query management capabilities.

Specified by:

tearDownQuery in class BigdataGraph

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 externalQueryId)

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 r)

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

getQueryById

public RunningQuery getQueryById(UUID queryId2)

Description copied from class: BigdataGraph

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

Specified by:

getQueryById in class BigdataGraph

Parameters:

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

isQueryCancelled

protected boolean isQueryCancelled(UUID queryId)

Description copied from class: BigdataGraph

Helper method to determine if a query was cancelled.

Specified by:

isQueryCancelled in class BigdataGraph

Returns:

isReadOnly

public boolean isReadOnly()

Description copied from class: BigdataGraph

Is this a read-only view of the graph?

Specified by:

isReadOnly in class BigdataGraph