com.bigdata.blueprints

Class BigdataGraphClient

java.lang.Object

com.bigdata.blueprints.BigdataGraph

com.bigdata.blueprints.BigdataGraphClient

All Implemented Interfaces:

com.tinkerpop.blueprints.Graph

public class BigdataGraphClient
extends BigdataGraph

This is a thin-client implementation of a Blueprints wrapper around the client library that interacts with the NanoSparqlServer. This is a functional implementation suitable for writing POCs - it is not a high performance implementation by any means (currently does not support caching or batched update). Does have a single "bulk upload" operation that wraps a method on RemoteRepository that will POST a graphml file to the blueprints layer of the bigdata server.

Author:

mikepersonick

See Also:

BigdataSailRemoteRepository}, BigdataSailRemoteRepositoryConnection}, RemoteRepository}

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>

Field Summary

Fields

Modifier and Type	Field and Description
protected static com.tinkerpop.blueprints.Features	FEATURES

Fields inherited from class com.bigdata.blueprints.BigdataGraph

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

Constructor Summary

Constructors

Constructor and Description
BigdataGraphClient(BigdataSailRemoteRepository repo)
BigdataGraphClient(BigdataSailRemoteRepository repo, BlueprintsValueFactory factory) Core implementation.
BigdataGraphClient(RemoteRepository repo)
BigdataGraphClient(RemoteRepository repo, BlueprintsValueFactory factory)
BigdataGraphClient(String sparqlEndpointURL)
BigdataGraphClient(String sparqlEndpointURL, BlueprintsValueFactory factory)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel(RunningQuery r) Kill a running query specified by the RunningQuery object.
void	cancel(String queryId) Kill a running query specified by the UUID String.
void	cancel(UUID queryId) Kill a running query specified by the UUID.
BigdataSailRemoteRepositoryConnection	cxn() Get a BigdataSailRemoteRepositoryConnection.
com.tinkerpop.blueprints.Features	getFeatures()
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
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?
void	loadGraphML(String file) Post a GraphML file to the remote server.
protected UUID	setupQuery(BigdataSailRepositoryConnection cxn, ASTContainer astContainer, QueryType queryType, String extQueryId) Embedded clients can override this to access query management capabilities.
void	shutdown() Shutdown the connection and repository (client-side, not server-side).
protected void	tearDownQuery(UUID queryId) Embedded clients can override this to access query management capabilities.

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, 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

Field Detail

FEATURES

protected static final com.tinkerpop.blueprints.Features FEATURES

Constructor Detail

BigdataGraphClient

public BigdataGraphClient(String sparqlEndpointURL)

Parameters:

sparqlEndpointURL - The URL of the SPARQL end point. This will be used to read and write on the graph using the blueprints API.

BigdataGraphClient

public BigdataGraphClient(String sparqlEndpointURL,
                  BlueprintsValueFactory factory)

Parameters:

sparqlEndpointURL - The URL of the SPARQL end point. This will be used to read and write on the graph using the blueprints API.

factory - The BlueprintsValueFactory.

BigdataGraphClient

public BigdataGraphClient(RemoteRepository repo)

BigdataGraphClient

public BigdataGraphClient(RemoteRepository repo,
                  BlueprintsValueFactory factory)

BigdataGraphClient

public BigdataGraphClient(BigdataSailRemoteRepository repo)

BigdataGraphClient

public BigdataGraphClient(BigdataSailRemoteRepository repo,
                  BlueprintsValueFactory factory)

Core implementation.

Parameters:

repo - The BigdataSailRemoteRepository for the desired graph.

factory - The BlueprintsValueFactory.

Method Detail

loadGraphML

public void loadGraphML(String file)
                 throws Exception

Post a GraphML file to the remote server. (Bulk-upload operation.)

Overrides:

loadGraphML in class BigdataGraph

Throws:

Exception

cxn

public BigdataSailRemoteRepositoryConnection cxn()
                                          throws Exception

Get a BigdataSailRemoteRepositoryConnection. TODO Review this now that we support read/write tx for BigdataSailRemoteRepositoryConnection (if namespace uses ISOLATABLE_INDICES).

Specified by:

cxn in class BigdataGraph

Throws:

Exception

shutdown

public void shutdown()

Shutdown the connection and repository (client-side, not server-side).

getFeatures

public com.tinkerpop.blueprints.Features getFeatures()

Specified by:

getFeatures in interface com.tinkerpop.blueprints.Graph

Overrides:

getFeatures in class BigdataGraph

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

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