oracle.pg.hbase

Class SparkUtils

java.lang.Object

oracle.pg.hbase.SparkUtils

All Implemented Interfaces:

SparkUtilsBase

public class SparkUtils
extends Object
implements SparkUtilsBase

This class implements SparkUtilsBase and it provides a set of convenient helper methods to facilitate running Apache Spark tasks against property graph data stored in Apache HBase.

Method Summary

Modifier and Type	Method and Description
String	getEdgeLabel(Object graphElementReprOnDB) When the given graph element is a repsentation of an Edge, returns the edge label.
Long	getElementId(Object graphElementReprOnDB) This method returns a graph element (Vertex or Edge) ID.
Object	getGraphElementReprOnDB(Object dbObject) This method returns a graph element representation stored in one of the underlying databases.
static SparkUtils	getInstance() A helper method to return an instance of SparkUtils
Long	getInVertexId(Object graphElementReprOnDB) When the given graph element is a repsentation of an Edge, returns the in-vertex (or destination) ID.
Long	getOutVertexId(Object graphElementReprOnDB) When the given graph element is a repsentation of an Edge, returns the out-vertex (or source) ID.
Set<String>	getPropertyNames(Object graphElementReprOnDB) This method returns a set of property names for a given graph element (Vertex or Edge).
Object	getPropertyValue(Object graphElementReprOnDB, String keyName) This method returns the property value of a graph element for a given property key.
boolean	isElementForEdge(Object graphElementReprOnDB) Returns true if the given graph element is a repsentation of an Edge.
boolean	isElementForVertex(Object graphElementReprOnDB) Returns true if the given graph element is a repsentation of a Vertex.

Methods inherited from class java.lang.Object

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

Method Detail

getEdgeLabel

public String getEdgeLabel(Object graphElementReprOnDB)

When the given graph element is a repsentation of an Edge, returns the edge label.

Specified by:

getEdgeLabel in interface SparkUtilsBase

getElementId

public Long getElementId(Object graphElementReprOnDB)

This method returns a graph element (Vertex or Edge) ID.

Specified by:

getElementId in interface SparkUtilsBase

getGraphElementReprOnDB

public Object getGraphElementReprOnDB(Object dbObject)

This method returns a graph element representation stored in one of the underlying databases. This representation is database specific and the return value should only be consumed by other APIs defined in this interface.

Specified by:

getGraphElementReprOnDB in interface SparkUtilsBase

getInstance

public static SparkUtils getInstance()

A helper method to return an instance of SparkUtils

getInVertexId

public Long getInVertexId(Object graphElementReprOnDB)

When the given graph element is a repsentation of an Edge, returns the in-vertex (or destination) ID.

Specified by:

getInVertexId in interface SparkUtilsBase

getOutVertexId

public Long getOutVertexId(Object graphElementReprOnDB)

When the given graph element is a repsentation of an Edge, returns the out-vertex (or source) ID.

Specified by:

getOutVertexId in interface SparkUtilsBase

getPropertyNames

public Set<String> getPropertyNames(Object graphElementReprOnDB)

This method returns a set of property names for a given graph element (Vertex or Edge). A NULL value will be returned if there is no properties (K/V pairs) in the given graph element.

Specified by:

getPropertyNames in interface SparkUtilsBase

getPropertyValue

public Object getPropertyValue(Object graphElementReprOnDB,
                               String keyName)
                        throws IOException,
                               ParseException

This method returns the property value of a graph element for a given property key.

Specified by:

getPropertyValue in interface SparkUtilsBase

Throws:

IOException

ParseException

isElementForEdge

public boolean isElementForEdge(Object graphElementReprOnDB)

Returns true if the given graph element is a repsentation of an Edge.

Specified by:

isElementForEdge in interface SparkUtilsBase

isElementForVertex

public boolean isElementForVertex(Object graphElementReprOnDB)

Returns true if the given graph element is a repsentation of a Vertex.

Specified by:

isElementForVertex in interface SparkUtilsBase