oracle.pg.hbase

Class SparkUtils

java.lang.Object

oracle.pg.hbase.SparkUtils

All Implemented Interfaces:

SparkUtilsBase

public class SparkUtils
extends java.lang.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
java.lang.String	getEdgeLabel(java.lang.Object graphElementReprOnDB) When the given graph element is a repsentation of an Edge, returns the edge label.
java.lang.Long	getElementId(java.lang.Object graphElementReprOnDB) This method returns a graph element (Vertex or Edge) ID.
java.lang.Object	getGraphElementReprOnDB(java.lang.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
java.lang.Long	getInVertexId(java.lang.Object graphElementReprOnDB) When the given graph element is a repsentation of an Edge, returns the in-vertex (or destination) ID.
java.lang.Long	getOutVertexId(java.lang.Object graphElementReprOnDB) When the given graph element is a repsentation of an Edge, returns the out-vertex (or source) ID.
java.util.Set<java.lang.String>	getPropertyNames(java.lang.Object graphElementReprOnDB) This method returns a set of property names for a given graph element (Vertex or Edge).
java.lang.Object	getPropertyValue(java.lang.Object graphElementReprOnDB, java.lang.String keyName) This method returns the property value of a graph element for a given property key.
boolean	isElementForEdge(java.lang.Object graphElementReprOnDB) Returns true if the given graph element is a repsentation of an Edge.
boolean	isElementForVertex(java.lang.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 java.lang.String getEdgeLabel(java.lang.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 java.lang.Long getElementId(java.lang.Object graphElementReprOnDB)

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

Specified by:

getElementId in interface SparkUtilsBase

getGraphElementReprOnDB

public java.lang.Object getGraphElementReprOnDB(java.lang.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 java.lang.Long getInVertexId(java.lang.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 java.lang.Long getOutVertexId(java.lang.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 java.util.Set<java.lang.String> getPropertyNames(java.lang.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 java.lang.Object getPropertyValue(java.lang.Object graphElementReprOnDB,
                                         java.lang.String keyName)
                                  throws java.io.IOException,
                                         java.text.ParseException

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

Specified by:

getPropertyValue in interface SparkUtilsBase

Throws:

java.io.IOException

java.text.ParseException

isElementForEdge

public boolean isElementForEdge(java.lang.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(java.lang.Object graphElementReprOnDB)

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

Specified by:

isElementForVertex in interface SparkUtilsBase