org.cloudgraph.maprdb.service

Class MaprDBGraphService

java.lang.Object

org.cloudgraph.maprdb.service.MaprDBGraphService

All Implemented Interfaces:

org.cloudgraph.mapreduce.GraphAccessor, org.cloudgraph.mapreduce.GraphMutator, org.cloudgraph.mapreduce.GraphService, org.plasma.sdo.access.DataAccessService, org.plasma.sdo.access.PlasmaDataAccessService

public class MaprDBGraphService
extends Object
implements org.plasma.sdo.access.PlasmaDataAccessService, org.cloudgraph.mapreduce.GraphService

Top level provider service implementing the DataAccessService interface and delegating to GraphQuery for serving data from HBase back to the client, and GraphDispatcher for propagating changes to one or more data graphs back to HBase.

CloudGraph™ is based on the Service Data Objects (SDO) 2.1 specification and is designed as a suite of SDO Data Access Services (DAS) under the PlasmaSDO™ Service Data Objects implementation.

Typical CRUD operations are provided across any full or partial data graph, and any "slice" of a graph or set of sub-graph slices can be returned using common SDO query mechanisms including XPath and others.

Since:

0.5

Author:

Scott Cinnamond

See Also:

DataAccessService, GraphQuery, GraphDispatcher

Field Summary

Fields

Modifier and Type	Field and Description
protected org.cloudgraph.core.ServiceContext	context

Constructor Summary

Constructors

Constructor and Description
MaprDBGraphService()

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit(commonj.sdo.DataGraph[] graphs, org.apache.hadoop.mapreduce.JobContext context)
org.plasma.sdo.core.SnapshotMap	commit(commonj.sdo.DataGraph[] dataGraphs, String username)
void	commit(commonj.sdo.DataGraph graph, org.apache.hadoop.mapreduce.JobContext context)
org.plasma.sdo.core.SnapshotMap	commit(commonj.sdo.DataGraph dataGraph, String username)
int	count(org.plasma.query.model.Query query)
int[]	count(org.plasma.query.model.Query[] queries)
commonj.sdo.DataGraph[]	find(org.plasma.query.model.Query query)
List<commonj.sdo.DataGraph[]>	find(org.plasma.query.model.Query[] queries)
commonj.sdo.DataGraph[]	find(org.plasma.query.model.Query query, int maxResults)
commonj.sdo.DataGraph[]	find(org.plasma.query.Query query, org.apache.hadoop.mapreduce.JobContext context)
io.reactivex.Observable<commonj.sdo.DataGraph>	findAsStream(org.plasma.query.model.Query query)
List<io.reactivex.Observable<commonj.sdo.DataGraph>>	findAsStream(org.plasma.query.model.Query[] queries)
io.reactivex.Observable<commonj.sdo.DataGraph>	findAsStream(org.plasma.query.model.Query query, int maxResults)
void	initialize(org.plasma.sdo.access.AccessServiceContext context)
protected void	log(org.plasma.query.model.Query query)
protected void	validate(org.plasma.query.model.Query query)

Methods inherited from class java.lang.Object

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

Field Detail

context

protected org.cloudgraph.core.ServiceContext context

Constructor Detail

MaprDBGraphService

public MaprDBGraphService()

Method Detail

initialize

public void initialize(org.plasma.sdo.access.AccessServiceContext context)

Specified by:

initialize in interface org.plasma.sdo.access.DataAccessService

close

public void close()

Specified by:

close in interface org.plasma.sdo.access.DataAccessService

count

public int count(org.plasma.query.model.Query query)

Specified by:

count in interface org.plasma.sdo.access.DataAccessService

count

public int[] count(org.plasma.query.model.Query[] queries)

Specified by:

count in interface org.plasma.sdo.access.DataAccessService

find

public commonj.sdo.DataGraph[] find(org.plasma.query.model.Query query)

Specified by:

find in interface org.plasma.sdo.access.DataAccessService

find

public commonj.sdo.DataGraph[] find(org.plasma.query.model.Query query,
                                    int maxResults)

Specified by:

find in interface org.plasma.sdo.access.DataAccessService

find

public List<commonj.sdo.DataGraph[]> find(org.plasma.query.model.Query[] queries)

Specified by:

find in interface org.plasma.sdo.access.DataAccessService

commit

public org.plasma.sdo.core.SnapshotMap commit(commonj.sdo.DataGraph dataGraph,
                                              String username)

Specified by:

commit in interface org.plasma.sdo.access.DataAccessService

commit

public org.plasma.sdo.core.SnapshotMap commit(commonj.sdo.DataGraph[] dataGraphs,
                                              String username)

Specified by:

commit in interface org.plasma.sdo.access.DataAccessService

validate

protected void validate(org.plasma.query.model.Query query)

log

protected void log(org.plasma.query.model.Query query)

find

public commonj.sdo.DataGraph[] find(org.plasma.query.Query query,
                                    org.apache.hadoop.mapreduce.JobContext context)
                             throws IOException

Specified by:

find in interface org.cloudgraph.mapreduce.GraphAccessor

Throws:

IOException

commit

public void commit(commonj.sdo.DataGraph graph,
                   org.apache.hadoop.mapreduce.JobContext context)
            throws IOException

Specified by:

commit in interface org.cloudgraph.mapreduce.GraphMutator

Throws:

IOException

commit

public void commit(commonj.sdo.DataGraph[] graphs,
                   org.apache.hadoop.mapreduce.JobContext context)
            throws IOException

Specified by:

commit in interface org.cloudgraph.mapreduce.GraphMutator

Throws:

IOException

findAsStream

public io.reactivex.Observable<commonj.sdo.DataGraph> findAsStream(org.plasma.query.model.Query query)

Specified by:

findAsStream in interface org.plasma.sdo.access.DataAccessService

findAsStream

public io.reactivex.Observable<commonj.sdo.DataGraph> findAsStream(org.plasma.query.model.Query query,
                                                                   int maxResults)

Specified by:

findAsStream in interface org.plasma.sdo.access.DataAccessService

findAsStream

public List<io.reactivex.Observable<commonj.sdo.DataGraph>> findAsStream(org.plasma.query.model.Query[] queries)

Specified by:

findAsStream in interface org.plasma.sdo.access.DataAccessService