public class OraclePropertyGraph extends OraclePropertyGraphBase
OraclePropertyGraphBase.OptimizationFlag
TransactionalGraph.Conclusion
Modifier and Type | Method and Description |
---|---|
void |
addAttributeToAllEdges(EdgeOpCallback eoc)
Adds an attribute to all edges based on the specified EdgeOpCallback.
|
void |
addAttributeToAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop)
Adds an attribute to all edges based on the specified EdgeOpCallback.
|
void |
addAttributeToAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop, ProgressListener pl)
Adds an attribute to all edges based on the specified EdgeOpCallback.
|
void |
addAttributeToAllVertices(VertexOpCallback voc)
Adds an attribute to all vertices based on the specified VertexOpCallback.
|
void |
addAttributeToAllVertices(VertexOpCallback voc, boolean skipStoreToCache, int dop)
Adds an attribute to all vertices based on the specified VertexOpCallback.
|
void |
addAttributeToAllVertices(VertexOpCallback voc, boolean skipStoreToCache, int dop, ProgressListener pl)
Adds an attribute to all vertices based on the specified VertexOpCallback.
|
Edge |
addEdge(Object id, Vertex outVertex, Vertex inVertex, String label)
This method adds an edge to the graph instance.
|
Vertex |
addVertex(Object id)
This method adds a vertex to the graph instance.
|
void |
clearCache()
This method clear the Vertex and Edge caches associated to this property graph instance.
|
void |
clearRepository()
This method removes all vertices and edges from this property graph instance.
|
void |
commit()
Commit changes done to this property graph instace.
|
static byte[] |
concatenate(byte[] ba1, byte[] ba2)
This method returns a byte array that concatenates the two given byte array If one of the argument is null, the return value will be the other argument.
|
static byte[] |
concatenate(byte[] ba1, byte[] ba2, byte[] ba3)
This method returns a byte array that concatenates the two given byte array If one of the argument is null, the return value will be the other argument.
|
long |
countEdges()
Counts all Edges
|
long |
countEdges(int dop)
Counts all Edges using parallel scans and the specified DOP
|
long |
countEdges(int dop, ProgressListener pl)
Counts all Edges using parallel scan and the specified DOP.
|
long |
countEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, int startSplitID, ProgressListener pl)
The splits are determined by # of regions & m_iNumSplitsPerRegion.
|
long |
countVertices()
Counts all vertices
|
long |
countVertices(int dop)
Counts all vertices using parallel scans and the specified DOP.
|
long |
countVertices(int dop, ProgressListener pl)
Counts all vertices using parallel scans and the specified DOP.
|
long |
countVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, int startSplitID, ProgressListener pl)
The splits are determined by # of regions & m_iNumSplitsPerRegion.
|
<T extends Element> |
createIndex(String indexName, Class<T> indexClass, Parameter... indexParameters)
Generates an index with a particular name, for a particular class, and of a particular type.
|
<T extends Element> |
createKeyIndex(String[] keys, Class<T> elementClass)
Creates an automatically maintained index for the given keys and element class.
|
<T extends Element> |
createKeyIndex(String key, Class<T> elementClass, Parameter... parameters)
Creates an automatic indexing structure for indexing provided key for element class.
|
void |
dropAllAutoIndices()
Drops all existing automatic indices (vertex and edges)
|
void |
dropAllIndices()
Drops all existing indices
|
void |
dropAllManualIndices()
Drops all existing manual indices (vertices and edges)
|
void |
dropIndex(String indexName)
Removes an index associated with the graph.
|
void |
dropIndexTable()
This method removes all indices meta data from this property graph instance.
|
<T extends Element> |
dropKeyIndex(String[] keys, Class<T> elementClass)
Removes an automatic indexing structure associated with indexing provided key for element class.
|
<T extends Element> |
dropKeyIndex(String key, Class<T> elementClass)
Removes an automatic indexing structure associated with indexing provided key for element class.
|
void |
flushHbaseCommits()
Flush HBase tables so property grpah changes are commited into HBase.
|
<T extends Element> |
getAutoIndex(Class<T> indexClass)
Gets an index from the graph by its name and index class.
|
int |
getBatchSize()
Get the size of the batch used for update operations.
|
String |
getCompression()
Get the type of compression used in the property graph tables
|
org.apache.hadoop.hbase.io.compress.Compression.Algorithm |
getCompressionAlgorithm(String compress)
An utility to get a Compression Algorithm based on the specified string
|
org.apache.hadoop.conf.Configuration |
getConfiguration()
This method returns the underlying Configuration instance used for HBase
|
org.apache.hadoop.hbase.io.encoding.DataBlockEncoding |
getDataBlockEncoding()
Gets the data block encoding algorithm used in block cache and optionally on disk for all property graph tables
|
OraclePropertyGraphBase.OptimizationFlag |
getDefaultEdgeOptFlag()
Get the OptimizationFlag for edges associated to this property graph
|
OracleIndexParameters |
getDefaultIndexParameters()
Get the default index parameters associated to this property graph.
|
OraclePropertyGraphBase.OptimizationFlag |
getDefaultVertexOptFlag()
Get the OptimizationFlag for vertices associated to this property graph
|
OracleEdge |
getEdge(Object id)
Return the edge referenced by the object identifier.
|
int |
getEdgeBlockCacheSize()
Gets the size of the block cache (in bytes) associated to the edge table
|
EdgeFilterCallback |
getEdgeFilterCallback()
Get the EdgeFilterCallback associated to this property graph
|
int |
getEdgeInitialNumRegions()
Get the initial number of regions defined for the HBase Edge tables associated to this property graph.
|
OracleEdgeBase |
getEdgeInstance(Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
Returns an instance of OracleEdgeBase.
|
OracleEdgeBase |
getEdgeInstance(OracleVertexBase outVertex, OracleVertexBase inVertex, String edgeLabel, Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
Returns an instance of OracleEdge
|
int |
getEdgePropertyNames(int dop, int timeout, Set<String> propertyNames)
Gets the property names of all edges.
|
int |
getEdgePropertyNames(int dop, int timeout, Set<String> propertyNames, ProgressListener pl)
Gets the property names of all edges using parallel scans and the specified DOP.
|
void |
getEdgePropertyNamesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, Set<String> propertyNames, long lStartTime, long lDeadline, int startSplitID, ProgressListener pl)
The splits are determined by # of regions & m_iNumSplitsPerRegion.
|
Iterable<Edge> |
getEdges()
Return an Iterable to all the edges in the graph.
|
Iterable<Edge> |
getEdges(String key)
Return an iterable to all the edges in the graph that have a particular key.
|
Iterable<Edge> |
getEdges(String[] keys)
Return an iterable to all the edges in the graph that have any of the specified keys.
|
Iterable<Edge> |
getEdges(String[] keys, EdgeFilterCallback efc)
Return an iterable to all the edges in the graph that have any of the specified keys and satisfy the specifed edge filter callback.
|
Iterable<Edge> |
getEdges(String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Return an iterable to all the edges in the graph that have any of the specified keys and satisfy the specifed edge filter callback.
|
Iterable<Edge> |
getEdges(String key, Object value)
Return an iterable to all matching edges that have a particular key/value property.
|
Iterable<Edge> |
getEdges(String key, Object value, boolean useWildCard)
Return an iterable to all matching edges that have a particular key/value property.
|
Iterable<Edge> |
getEdges(String key, Object value, boolean acceptWildcard, boolean preferredLuceneQuery)
Return an iterable to all the vertices in the graph that have a particular key/value property.
|
Iterable<Edge> |
getEdges(String key, Object value, Class dtClass, boolean acceptWildcard)
Return an iterable to all matching edges that have a particular key/value property.
|
Iterable<Edge> |
getEdges(String key, Object value, Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery)
Return an iterable to all the vertices in the graph that have a particular key/value property.
|
Iterable<Edge>[] |
getEdgesFromKey(org.apache.hadoop.hbase.client.HConnection[] conns, boolean skipStoreToCache, int startSplitID, String[] keys)
Return an iterable to all the edges in the graph that have a particular key/value property.
|
int |
getEdgeSndIndexBlockCacheSize()
Gets the size of the block cache (in bytes) associated to the secondary index edge table
|
String |
getEdgeSndIndexTabName()
Get the name of the HBase table used to store secondary indexes on edges in this property graph.
|
long |
getEdgeSndIndexWriteBufferSize()
Set the write buffer size associated to the edge secondary index table
|
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, boolean bClonedGraph)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, EdgeFilterCallback efc)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, OraclePropertyGraphBase.OptimizationFlag flag)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String key)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys, boolean bClonedGraph, EdgeFilterCallback efc)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys, boolean bClonedGraph, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String key, boolean bClonedGraph)
Gets an array of
Iterable objects that hold all the edges in the graph. |
int |
getEdgeTableSplits()
Get the number of Edge table splits based on the current number of splits per region associated to this graph and the number of regions in the edge table.
|
String |
getEdgeTabName()
Get the name of the HBase table used to store edges in this property graph.
|
long |
getEdgeWriteBufferSize()
Set the write buffer size associated to the edge table
|
Features |
getFeatures()
Get the particular features of the graph implementation.
|
String |
getGraphName()
This method returns the name of this property graph instance
|
<T extends Element> |
getIndex(String indexName, Class<T> indexClass)
Gets a manual index from the graph by its name and index class.
|
<T extends Element> |
getIndexedKeys(Class<T> elementClass)
Returns all the index keys associated with a particular element class.
|
<T extends Element> |
getIndexParameters(String indexName, Class<T> indexClass)
Get the index parameters associated to this property graph.
|
Iterable<Index<? extends Element>> |
getIndices()
Gets all the indices maintained by the graph.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, int initialNumRegions)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, int initialNumRegions, int splitsPerRegion)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, int initialNumRegions, int splitsPerRegion, int blockCacheSize)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, org.apache.hadoop.hbase.io.encoding.DataBlockEncoding dbe, int splitsPerRegion, int blockCacheSize, int initialVertexNumRegions, int initialEdgeNumRegions)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, int initialNumRegions)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, int initialNumRegions, int splitsPerRegion)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, int initialNumRegions, int splitsPerRegion, int blockCacheSize)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, int splitsPerRegion, int blockCacheSize, int initialVertexNumRegions, int initialEdgeNumRegions)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(oracle.pgx.config.PgHbaseGraphConfig config)
Returns an instance of OraclePropertyGraph using a PGX PgHbaseGraphConfig object.
|
static OraclePropertyGraph |
getInstanceWithSplits(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, int splitsPerRegion)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided and the specified number of splits per region.
|
int |
getLuceneBlockCacheSize()
Gets the size of the block cache (in bytes) associated to the Lucene index table
|
String |
getLuceneTabName()
Get the name of the HBase table used to store index metadata in this property graph.
|
long |
getLuceneWriteBufferSize()
Set the write buffer size associated to the Lucene index table
|
long |
getMaxEdgeID()
Get max edge ID
|
long |
getMaxEdgeID(int dop)
Get max edge ID using parallel scans and the specified DOP.
|
long |
getMaxEdgeID(int dop, ProgressListener pl)
Get the maximal edge ID using parallel scan and the specified DOP.
|
long |
getMaxVertexID()
Get min Vertex ID
|
long |
getMaxVertexID(int dop)
Get min vertex ID using parallel scans and the specified DOP.
|
long |
getMaxVertexID(int dop, ProgressListener pl)
Get min vertex ID using parallel scans and the specified DOP.
|
long |
getMinEdgeID()
Get min edge ID
|
long |
getMinEdgeID(int dop)
Get min edge ID using parallel scans and the specified DOP.
|
long |
getMinEdgeID(int dop, ProgressListener pl)
Get the minimum edge ID using parallel scan and the specified DOP.
|
long |
getMinVertexID()
Get min Vertex ID
|
long |
getMinVertexID(int dop)
Get min vertex ID using parallel scans and the specified DOP.
|
long |
getMinVertexID(int dop, ProgressListener pl)
Get min vertex ID using parallel scans and the specified DOP.
|
int |
getNumSplitsPerRegion()
Get the number of splits per region to use when scanning vertices/edges
|
long |
getOperationQueueSize()
Get the size of the operation queue
|
HBaseIndexManager |
getOracleIndexManager()
Gets the OracleIndexManager object associated to this property graph instance.
|
ProgressListener |
getProgressListener()
Gets the ProgressListener associated to this property graph.
|
int |
getQueueSize()
This method returns the queue size.
|
int |
getSaltSize()
Gets the salt size
|
int |
getScanCachingSize()
Get the caching size used in Scan operations
|
int |
getSecondaryIndexNumBuckets()
Return the number of buckets used to store secondary index data into the vertex/edge secondary index tables
|
OracleVertex |
getVertex(Object id)
Return the vertex referenced by the object identifier.
|
int |
getVertexBlockCacheSize()
Gets the size of the block cache (in bytes) associated to the vertex table
|
VertexFilterCallback |
getVertexFilterCallback()
Get the VertexFilterCallback associated to this property graph
|
int |
getVertexInitialNumRegions()
Get the initial number of regions defined for the HBase Vertex tables associated to this property graph.
|
OracleVertexBase |
getVertexInstance(Long vid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
Returns an instance of OracleVertexBase.
|
int |
getVertexPropertyNames(int dop, int timeout, Set<String> propertyNames)
Gets the property names of all vertices using parallel scans and the specified DOP.
|
int |
getVertexPropertyNames(int dop, int timeout, Set<String> propertyNames, ProgressListener pl)
Gets the property names of all vertices using parallel scans and the specified DOP.
|
void |
getVertexPropertyNamesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, Set<String> propertyNames, long lStartTime, long lDeadline, int startSplitID, ProgressListener pl)
The splits are determined by # of regions & m_iNumSplitsPerRegion.
|
int |
getVertexSndIndexBlockCacheSize()
Gets the size of the block cache (in bytes) associated to the secondary index vertex table
|
String |
getVertexSndIndexTabName()
Get the name of the HBase table used to store secondary indexes on vertices in this property graph.
|
long |
getVertexSndIndexWriteBufferSize()
Get the write buffer size associated to the vertex secondary index table
|
int |
getVertexTableSplits()
Get the number of Vertex table splits based on the current number of splits per region associated to this graph and the number of regions in the vertex table.
|
String |
getVertexTabName()
Get the name of the HBase table used to store vertices in this property graph.
|
long |
getVertexWriteBufferSize()
Get the write buffer size associated to the vertex table
|
Iterable<Vertex> |
getVertices()
Return an iterable to all the vertices in the graph.
|
Iterable<Vertex> |
getVertices(String key)
Return an iterable to all the vertices in the graph that have a particular key.
|
Iterable<Vertex> |
getVertices(String[] keys)
Return an iterable to all the vertices in the graph that have any of the specified keys.
|
Iterable<Vertex> |
getVertices(String[] keys, VertexFilterCallback vfc)
Return an iterable to all the vertices in the graph that have any of the specified keys and satisfy the specifed vertex filter callback.
|
Iterable<Vertex> |
getVertices(String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Return an iterable to all the vertices in the graph that have any of the specified keys and satisfy the specifed vertex filter callback.
|
Iterable<Vertex> |
getVertices(String key, Object value)
Return an iterable to all matching vertices that have a particular key/value property.
|
Iterable<Vertex> |
getVertices(String key, Object value, boolean useWildCards)
Return an iterable to all matching vertices that have a particular key/value property.
|
Iterable<Vertex> |
getVertices(String key, Object value, boolean acceptWildcard, boolean preferredLuceneQuery)
Return an iterable to all matching vertices that have a particular key/value property.
|
Iterable<Vertex> |
getVertices(String key, Object value, Class dtClass, boolean acceptWildcard)
Return an iterable to all matching vertices that have a particular key/value property.
|
Iterable<Vertex> |
getVertices(String key, Object value, Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery)
Return an iterable to all matching vertices that have a particular key/value property.
|
Iterable<Vertex>[] |
getVerticesFromKey(org.apache.hadoop.hbase.client.HConnection[] conns, boolean skipStoreToCache, int startSplitID, String[] keys)
Return an iterable to all the vertices in the graph that have a particular key/value property.
|
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID)
Gets an array of
Iterable objects that hold all the vertices in the graph. |
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, boolean bClonedGraph)
Gets an array of
Iterable objects that hold all the vertices in the graph. |
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, OraclePropertyGraphBase.OptimizationFlag flag)
Gets an array of
Iterable objects that hold all the vertices in the graph. |
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String key)
Gets an array of
Iterable objects that hold all the vertices in the graph matching the specified key. |
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys)
Gets an array of
Iterable objects that hold all the vertices in the graph matching any of the specifed keys described in the vertex filter callback. |
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys, boolean bCloneGraph, VertexFilterCallback vfc)
Gets an array of
Iterable objects that hold all the vertices in the graph statisfying the conditions described in the vertex filter callback. |
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys, boolean bCloneGraph, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Gets an array of
Iterable objects that hold all the vertices in the graph statisfying the conditions described in the vertex filter callback. |
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String key, boolean bCloneGraph)
Gets an array of
Iterable objects that hold all the vertices in the graph matching the specified key. |
Iterable<Vertex>[] |
getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Gets an array of
Iterable objects that hold all the vertices in the graph statisfying the conditions described in the vertex filter callback. |
long |
getWriteBufferSize()
Get the write buffer size associated to the vertex table
|
boolean |
isEdgeAutoIndexEnabled(String key)
Validates if the edge auto index is currently enabled
|
boolean |
isEmpty()
Checks if this property graph is empty
|
boolean |
isVertexAutoIndexEnabled(String key)
Validates if the vertex auto index is currently enabled
|
static org.apache.hadoop.conf.Configuration |
prepareSecureConfig(org.apache.hadoop.conf.Configuration config, String hbaseSecAuth, String hadoopSecAuth, String hmKerberosPrincipal, String rsKerberosPrincipal, String userPrincipal, String keytab)
Prepares the HBase configuration object to work with HBase secure cluster
|
GraphQuery |
query()
Returns a GraphQuery to query for vertices or edges in the graph by their properties.
|
static void |
quietlyClose(org.apache.hadoop.hbase.client.HTable htable)
Quietly close the specified HTable object.
|
static void |
quietlyClose(org.apache.hadoop.hbase.client.HTableInterface htable)
Quietly close the specified HTableInterface object.
|
void |
removeAttributeFromAllEdges(EdgeOpCallback eoc)
Removes an attribute from all edges based on the specified EdgeOpCallback.
|
void |
removeAttributeFromAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop)
Removes an attribute from all edges based on the specified EdgeOpCallback.
|
void |
removeAttributeFromAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop, ProgressListener pl)
Removes an attribute from all edges based on the specified EdgeOpCallback.
|
void |
removeAttributeFromAllVertices(VertexOpCallback voc)
Removes an attribute from all vertices based on the specified VertexOpCallback.
|
void |
removeAttributeFromAllVertices(VertexOpCallback voc, boolean skipStoreToCache, int dop)
Removes an attribute from all vertices based on the specified VertexOpCallback.
|
void |
removeAttributeFromAllVertices(VertexOpCallback voc, boolean skipStoreToCache, int dop, ProgressListener pl)
Removes an attribute from all vertices based on the specified VertexOpCallback.
|
void |
removeEdge(Edge edge)
Remove the provided edge from the graph.
|
void |
removeVertex(Vertex vertex)
Remove the provided vertex from the graph.
|
void |
rollback()
Rollbacks the operations done to this property graph instance
|
static byte[] |
saltEdge(byte[] ba)
Salts an edge ID represented as a byte array
|
static byte[] |
saltVertex(byte[] ba)
Salts a vertex ID represented as a byte array
|
static String |
serializableToStr(Serializable seri)
Convert from a Java Serializable object to a String encoding.
|
void |
setBatchSize(int batchsize)
Set the size of the batch used for update operations.
|
void |
setCompression(String compress)
Set the type of compression used in the property graph tables.
|
void |
setDataBlockEncoding(org.apache.hadoop.hbase.io.encoding.DataBlockEncoding dbe)
Set the data block encoding used in the property graph tables.
|
void |
setDefaultEdgeOptFlag(OraclePropertyGraphBase.OptimizationFlag eof)
Set the edge optimization flag associated to this property graph
|
void |
setDefaultIndexParameters(OracleIndexParameters indexParams)
Set the default index parameters associated to this property graph.
|
void |
setDefaultVertexOptFlag(OraclePropertyGraphBase.OptimizationFlag vof)
Set the default optimization flag for vertices associated to this property graph
|
void |
setEdgeBlockCacheSize(int blockCSize)
Set the size of the block cache (in bytes) associated to the edge table This is a meta data operation, so changes to this setting will show after clearing the repository and recreating the edge tables.
|
void |
setEdgeFilterCallback(EdgeFilterCallback efc)
Set the default EdgeFilterCallback associated to this property graph
|
void |
setEdgeInitialNumRegions(int numRegions)
Set the initial number of regions defined for the HBase edge tables associated to this property graph.
|
void |
setEdgeSndIndexBlockCacheSize(int blockCSize)
Set the size of the block cache (in bytes) associated to the edge secondary table This is a meta data operation, so changes to this setting will show after clearing the repository and recreating the edge tables.
|
void |
setEdgeSndIndexWriteBufferSize(long writebuffer)
Set the size of the write buffer associated to the edge secondary index table
|
void |
setEdgeWriteBufferSize(long writebuffer)
Set the maximum size of the write buffer associated to the edge table
|
void |
setIndexLuceneWriteBufferSize(long writebuffer)
Set the maxium size of the write buffer associated to the Lucene index table
|
void |
setInitialNumRegions(int numRegions)
Set the initial number of regions defined for the HBase tables associated to this property graph.
|
void |
setLuceneBlockCacheSize(int blockCSize)
Set the size of the block cache (in bytes) associated to the Lucene index table This is a meta data operation, so changes to this setting will show after clearing the repository and recreating the lucene tables.
|
void |
setNumSplitsPerRegion(int iNumSplitsPerRegion)
Set the number of splits per region to use when scanning vertices/edges
|
void |
setProgressListener(ProgressListener pl)
Sets the ProgressListener associated to this property graph.
|
void |
setQueueSize(int size)
This method sets the queue size.
|
void |
setScanCachingSize(int iScanCachingSize)
Set the caching size used in Scan operations
|
void |
setVertexBlockCacheSize(int blockCSize)
Set the size of the block cache (in bytes) associated to the vertex table
|
void |
setVertexFilterCallback(VertexFilterCallback vfc)
Set the default VertexFilterCallback associated to this property graph
|
void |
setVertexInitialNumRegions(int numRegions)
Set the initial number of regions defined for the HBase Vertex tables associated to this property graph.
|
void |
setVertexSndIndexBlockCacheSize(int blockCSize)
Set the size of the block cache (in bytes) associated to the vertex secondary table This is a meta data operation, so changes to this setting will show after clearing the repository and recreating the vertex tables.
|
void |
setVertexSndIndexWriteBufferSize(long writebuffer)
Set the maximum size of the write buffer associated to the vertex secondary index table
|
void |
setVertexWriteBufferSize(long writebuffer)
Set the maximum size of the write buffer associated to the vertex table
|
void |
setWriteBufferSize(long writebuffer)
Set the maximum size of the write buffer associated to the graph tables
|
void |
shutdown()
A shutdown function is required to properly close the graph.
|
void |
startTransaction()
Start a transaction.
|
void |
stopTransaction(TransactionalGraph.Conclusion conclusion)
Stop the current transaction.
|
static Object |
strToSerializable(String s)
Convert from a String encoding to a Serializable object
|
String |
toString()
Returns a very succinct String representation of this Graph instance
|
getConfig, getShortestPath, getShortestPath, getVertexPropertyNames, getVertexPropertyNames, sum
public void addAttributeToAllEdges(EdgeOpCallback eoc)
eoc
- an EdgeOpCallBack object.public void addAttributeToAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop)
eoc
- an EdgeOpCallBack object.skipStoreToCache
- if true, the edges instances will not be stored into the cache.dop
- a positive integer defining the number of threads to use when parallel processing the edges.public void addAttributeToAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop, ProgressListener pl)
eoc
- an EdgeOpCallBack object.skipStoreToCache
- if true, the edges instances will not be stored into the cache.dop
- a positive integer defining the number of threads to use when parallel processing the edges.pl
- a ProgressListener object.public void addAttributeToAllVertices(VertexOpCallback voc)
voc
- a VertexOpCallBack object.public void addAttributeToAllVertices(VertexOpCallback voc, boolean skipStoreToCache, int dop)
voc
- a VertexOpCallBack object.skipStoreToCache
- if true, the vertices instances will not be stored into the cache.dop
- a positive integer defining the number of threads to use when parallel processing the vertices.public void addAttributeToAllVertices(VertexOpCallback voc, boolean skipStoreToCache, int dop, ProgressListener pl)
voc
- a VertexOpCallBack object.skipStoreToCache
- if true, the vertices instances will not be stored into the cache.dop
- a positive integer defining the number of threads to use when parallel processing the vertices.pl
- a ProgressListener object.public Edge addEdge(Object id, Vertex outVertex, Vertex inVertex, String label)
id
- the id of the vertexoutVertex
- has to be of type OracleVertexinVertex
- has to be of type OracleVertexpublic Vertex addVertex(Object id)
id
- vertex idVertex
objectpublic void clearCache()
public void clearRepository() throws org.apache.hadoop.hbase.MasterNotRunningException, IOException
clearRepository
in class OraclePropertyGraphBase
org.apache.hadoop.hbase.MasterNotRunningException
IOException
public void commit()
public static byte[] concatenate(byte[] ba1, byte[] ba2)
public static byte[] concatenate(byte[] ba1, byte[] ba2, byte[] ba3)
public long countEdges()
public long countEdges(int dop)
dop
- a positive integer defining the number of threads to use when parallel scanning the edges.public long countEdges(int dop, ProgressListener pl)
dop
- a positive integer defining the number of threads to use when parallel scanning the edges.pl
- a ProgressListener object.public long countEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, int startSplitID, ProgressListener pl)
startSplitID
- starts from 0.public long countVertices()
public long countVertices(int dop)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.public long countVertices(int dop, ProgressListener pl)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pl
- a ProgressListener object.public long countVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, int startSplitID, ProgressListener pl)
startSplitID
- starts from 0.public <T extends Element> Index<T> createIndex(String indexName, Class<T> indexClass, Parameter... indexParameters)
indexName
- the name of the indexindexClass
- the element class that this index is indexing (can be base class)indexParameters
- a collection of parameters for the underlying index implementationpublic <T extends Element> void createKeyIndex(String[] keys, Class<T> elementClass)
keys
- an array of keys to create the index for.elementClass
- the element class that the index is for.public <T extends Element> void createKeyIndex(String key, Class<T> elementClass, Parameter... parameters)
key
- the key to create the index for.elementClass
- the element class that the index is for.parameters
- a collection of parameters for the underlying index implementation.public void dropAllAutoIndices()
public void dropAllIndices()
dropAllIndices
in class OraclePropertyGraphBase
public void dropAllManualIndices()
public void dropIndex(String indexName)
indexName
- the name of the index to droppublic void dropIndexTable() throws org.apache.hadoop.hbase.MasterNotRunningException, IOException
org.apache.hadoop.hbase.MasterNotRunningException
IOException
public <T extends Element> void dropKeyIndex(String[] keys, Class<T> elementClass)
keys
- an array of keys to drop the index for.elementClass
- the element class that the index is for.public <T extends Element> void dropKeyIndex(String key, Class<T> elementClass)
key
- the key to drop the index for.elementClass
- the element class that the index is for.public void flushHbaseCommits()
public <T extends Element> Index<T> getAutoIndex(Class<T> indexClass)
public int getBatchSize()
public String getCompression()
public org.apache.hadoop.hbase.io.compress.Compression.Algorithm getCompressionAlgorithm(String compress)
public org.apache.hadoop.conf.Configuration getConfiguration()
public org.apache.hadoop.hbase.io.encoding.DataBlockEncoding getDataBlockEncoding()
public OraclePropertyGraphBase.OptimizationFlag getDefaultEdgeOptFlag()
public OracleIndexParameters getDefaultIndexParameters()
getDefaultIndexParameters
in class OraclePropertyGraphBase
OracleIndexParameters
object.public OraclePropertyGraphBase.OptimizationFlag getDefaultVertexOptFlag()
public OracleEdge getEdge(Object id)
public int getEdgeBlockCacheSize()
public EdgeFilterCallback getEdgeFilterCallback()
public int getEdgeInitialNumRegions()
public OracleEdgeBase getEdgeInstance(Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getEdgeInstance
in class OraclePropertyGraphBase
public OracleEdgeBase getEdgeInstance(OracleVertexBase outVertex, OracleVertexBase inVertex, String edgeLabel, Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getEdgeInstance
in class OraclePropertyGraphBase
public int getEdgePropertyNames(int dop, int timeout, Set<String> propertyNames)
dop
- a positive integer defining the number of threads to use when parallel scanning the edgestimeout
- time out in the unit of secondspropertyNames
- a set of property names to be returnedpublic int getEdgePropertyNames(int dop, int timeout, Set<String> propertyNames, ProgressListener pl)
dop
- a positive integer defining the number of threads to use when parallel scanning the edgestimeout
- time out in the unit of secondspropertyNames
- a set of property names to be returnedpl
- a ProgressListener object.public void getEdgePropertyNamesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, Set<String> propertyNames, long lStartTime, long lDeadline, int startSplitID, ProgressListener pl)
startSplitID
- starts from 0.public Iterable<Edge> getEdges(String key)
getEdges
in class OraclePropertyGraphBase
key
- name of the property. It can be NULL which implies all edges in the graph will be returned.public Iterable<Edge> getEdges(String[] keys)
getEdges
in class OraclePropertyGraphBase
keys
- an array of property key names. It can be NULL which implies all edges in the graph will be returned.public Iterable<Edge> getEdges(String[] keys, EdgeFilterCallback efc)
keys
- an array of property key names. It can be NULL which implies all edges in the graph satisfying the edge filter callback will be returned.efc
- a EdgeFilterCallback
object specifying the conditions to keep an edge in the iterable.public Iterable<Edge> getEdges(String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
keys
- an array of property key names. It can be NULL which implies all vertices in the graph satisfying the edge filter callback will be returned.efc
- a EdgeFilterCallback
object specifying the conditions to keep a edge in the iterable.flag
- an OptimizationFlag object specifying if a partial or complete edge object will be returned. It can be NULL which implies the edges created must be complete.public Iterable<Edge> getEdges(String key, Object value)
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all edges with the given key to be returned.public Iterable<Edge> getEdges(String key, Object value, boolean useWildCard)
getEdges
in class OraclePropertyGraphBase
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all edges with the given key to be returned.useWildCard
- specifies if wild cards can be used in the value object. Wild cards can be used only when an automatic text index on the given key is present.public Iterable<Edge> getEdges(String key, Object value, boolean acceptWildcard, boolean preferredLuceneQuery)
public Iterable<Edge> getEdges(String key, Object value, Class dtClass, boolean acceptWildcard)
getEdges
in class OraclePropertyGraphBase
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all edges with the given key to be returned.dtClass
- the datatype of the value objectacceptWildcard
- specifies if wild cards can be used in the value object. Wild cards can be used only when an automatic text index on the given key is present.public Iterable<Edge> getEdges(String key, Object value, Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery)
public Iterable<Edge>[] getEdgesFromKey(org.apache.hadoop.hbase.client.HConnection[] conns, boolean skipStoreToCache, int startSplitID, String[] keys)
public int getEdgeSndIndexBlockCacheSize()
public String getEdgeSndIndexTabName()
public long getEdgeSndIndexWriteBufferSize()
public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, boolean bClonedGraph)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, EdgeFilterCallback efc)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String key)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys, boolean bClonedGraph, EdgeFilterCallback efc)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys, boolean bClonedGraph, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Edge>[] getEdgesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String key, boolean bClonedGraph)
Iterable
objects that hold all the edges in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the edges instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public int getEdgeTableSplits() throws IOException
IOException
public String getEdgeTabName()
public long getEdgeWriteBufferSize()
public Features getFeatures()
public String getGraphName()
getGraphName
in class OraclePropertyGraphBase
public <T extends Element> Index<T> getIndex(String indexName, Class<T> indexClass)
public <T extends Element> Set<String> getIndexedKeys(Class<T> elementClass)
elementClass
- the element class that the index is for.public <T extends Element> OracleIndexParameters getIndexParameters(String indexName, Class<T> indexClass)
OracleIndexParameters
object.public Iterable<Index<? extends Element>> getIndices()
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphorg.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, int initialNumRegions) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphinitialNumRegions
- the initial number of regions used for vertex/edge tables. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, int initialNumRegions, int splitsPerRegion) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphinitialNumRegions
- the initial number of regions used for vertex/edge tables. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.splitsPerRegion
- a positive integer specifying the number of splits per region to use when scanning vertices/edges.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, int initialNumRegions, int splitsPerRegion, int blockCacheSize) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphinitialNumRegions
- the initial number of regions used for vertex/edge tables. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.splitsPerRegion
- a positive integer specifying the number of splits per region to use when scanning vertices/edges.blockCacheSize
- the size of the block cache (in bytes) used for vertex/edge tables. Blocksize to use when writing out storefiles/hfiles on these tables.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, org.apache.hadoop.hbase.io.encoding.DataBlockEncoding dbe, int splitsPerRegion, int blockCacheSize, int initialVertexNumRegions, int initialEdgeNumRegions) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphcompress
- the compression used in the property graph tablesdbe
- the data block encoding used in the property graph tablessplitsPerRegion
- a positive integer specifying the number of splits per region to use when scanning vertices/edges.blockCacheSize
- the size of the block cache (in bytes) used for vertex/edge tables. Blocksize to use when writing out storefiles/hfiles on these tables.initialVertexNumRegions
- the initial number of regions used for vertex table. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.initialEdgeNumRegions
- the initial number of regions used for edge table. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, int initialNumRegions) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphcompress
- the compression used in the property graph tablesinitialNumRegions
- the initial number of regions used for vertex/edge tables. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, int initialNumRegions, int splitsPerRegion) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphcompress
- the compression used in the property graph tablesinitialNumRegions
- the initial number of regions used for vertex/edge tables. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.splitsPerRegion
- a positive integer specifying the number of splits per region to use when scanning vertices/edges.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, int initialNumRegions, int splitsPerRegion, int blockCacheSize) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphcompress
- the compression used in the property graph tablesinitialNumRegions
- the initial number of regions used for vertex/edge tables. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.splitsPerRegion
- a positive integer specifying the number of splits per region to use when scanning vertices/edges.blockCacheSize
- the size of the block cache (in bytes) used for vertex/edge tables. Blocksize to use when writing out storefiles/hfiles on these tables.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, String compress, int splitsPerRegion, int blockCacheSize, int initialVertexNumRegions, int initialEdgeNumRegions) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.szGraphName
- the name of the graphcompress
- the compression used in the property graph tablessplitsPerRegion
- a positive integer specifying the number of splits per region to use when scanning vertices/edges.blockCacheSize
- the size of the block cache (in bytes) used for vertex/edge tables. Blocksize to use when writing out storefiles/hfiles on these tables.initialVertexNumRegions
- the initial number of regions used for vertex table. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.initialEdgeNumRegions
- the initial number of regions used for edge table. Both vertex and edge tables will be created using the specified number of regions. If the graph already exists, a clearRepository operation must be executed in order to truncate the tables and set the new number of regions.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstance(oracle.pgx.config.PgHbaseGraphConfig config) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
config
- a PgHbaseGraphConfig
object.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public static OraclePropertyGraph getInstanceWithSplits(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.HConnection hconn, String szGraphName, int splitsPerRegion) throws org.apache.hadoop.hbase.MasterNotRunningException, org.apache.hadoop.hbase.ZooKeeperConnectionException, IOException
conf
- the Configuration object with all the HBase connection information.hconn
- an HConnection
object handling a connection to HBase.splitsPerRegion
- a positive integer specifying the number of splits per region to use when scanning vertices/edges.org.apache.hadoop.hbase.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public int getLuceneBlockCacheSize()
public String getLuceneTabName()
public long getLuceneWriteBufferSize()
public long getMaxEdgeID()
public long getMaxEdgeID(int dop)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.public long getMaxEdgeID(int dop, ProgressListener pl)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pl
- a ProgressListener object.public long getMaxVertexID()
public long getMaxVertexID(int dop)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.public long getMaxVertexID(int dop, ProgressListener pl)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.public long getMinEdgeID()
public long getMinEdgeID(int dop)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.public long getMinEdgeID(int dop, ProgressListener pl)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pl
- a ProgressListener object.public long getMinVertexID()
public long getMinVertexID(int dop)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.public long getMinVertexID(int dop, ProgressListener pl)
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.public int getNumSplitsPerRegion()
public long getOperationQueueSize()
public HBaseIndexManager getOracleIndexManager()
getOracleIndexManager
in class OraclePropertyGraphBase
HBaseIndexManager
object.public ProgressListener getProgressListener()
public int getQueueSize()
public int getSaltSize()
public int getScanCachingSize()
public int getSecondaryIndexNumBuckets()
public OracleVertex getVertex(Object id)
public int getVertexBlockCacheSize()
public VertexFilterCallback getVertexFilterCallback()
public int getVertexInitialNumRegions()
public OracleVertexBase getVertexInstance(Long vid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getVertexInstance
in class OraclePropertyGraphBase
public int getVertexPropertyNames(int dop, int timeout, Set<String> propertyNames)
dop
- a positive integer defining the number of threads to use when parallel scanning the verticestimeout
- time out in the unit of secondspropertyNames
- a set of property names to be returnedpublic int getVertexPropertyNames(int dop, int timeout, Set<String> propertyNames, ProgressListener pl)
dop
- a positive integer defining the number of threads to use when parallel scanning the verticestimeout
- time out in the unit of secondspropertyNames
- a set of property names to be returnedpl
- a ProgressListener object.public void getVertexPropertyNamesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, Set<String> propertyNames, long lStartTime, long lDeadline, int startSplitID, ProgressListener pl)
startSplitID
- starts from 0.public int getVertexSndIndexBlockCacheSize()
public String getVertexSndIndexTabName()
public long getVertexSndIndexWriteBufferSize()
public int getVertexTableSplits() throws IOException
IOException
public String getVertexTabName()
public long getVertexWriteBufferSize()
public Iterable<Vertex> getVertices()
public Iterable<Vertex> getVertices(String key)
getVertices
in class OraclePropertyGraphBase
key
- name of the property. It can be NULL which implies all vertices in the graph will be returned.public Iterable<Vertex> getVertices(String[] keys)
getVertices
in class OraclePropertyGraphBase
keys
- an array of property key names. It can be NULL which implies all vertices in the graph will be returned.public Iterable<Vertex> getVertices(String[] keys, VertexFilterCallback vfc)
keys
- an array of property key names. It can be NULL which implies all vertices in the graph satisfying the vertex filter callback will be returned.vfc
- a VertexFilterCallback
object specifying the conditions to keep a vertex in the iterable.public Iterable<Vertex> getVertices(String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
keys
- an array of property key names. It can be NULL which implies all vertices in the graph satisfying the vertex filter callback will be returned.vfc
- a VertexFilterCallback
object specifying the conditions to keep a vertex in the iterable.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.public Iterable<Vertex> getVertices(String key, Object value)
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all vertices with the given key to be returned.public Iterable<Vertex> getVertices(String key, Object value, boolean useWildCards)
getVertices
in class OraclePropertyGraphBase
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all vertices with the given key to be returned.useWildCards
- specifies if wild cards can be used in the value object. Wild cards can be used only when an automatic text index on the given key is present.public Iterable<Vertex> getVertices(String key, Object value, boolean acceptWildcard, boolean preferredLuceneQuery)
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all vertices with the given key to be returned.acceptWildcard
- specifies if wild cards can be used in the value object. Wild cards can be used only when an automatic text index on the given key is present.preferredLuceneQuery
- if true, a look up to the automatic index will be executed to find the matches.public Iterable<Vertex> getVertices(String key, Object value, Class dtClass, boolean acceptWildcard)
getVertices
in class OraclePropertyGraphBase
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all vertices with the given key to be returned.dtClass
- the datatype of the value objectacceptWildcard
- specifies if wild cards can be used in the value object. Wild cards can be used only when an automatic text index on the given key is present.public Iterable<Vertex> getVertices(String key, Object value, Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery)
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all vertices with the given key to be returned.dtClass
- the datatype of the value objectacceptWildcard
- specifies if wild cards can be used in the value object. Wild cards can be used only when an automatic text index on the given key is present.preferredLuceneQuery
- if true, a look up to the automatic index will be executed to find the matches.public Iterable<Vertex>[] getVerticesFromKey(org.apache.hadoop.hbase.client.HConnection[] conns, boolean skipStoreToCache, int startSplitID, String[] keys)
public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID)
Iterable
objects that hold all the vertices in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, boolean bClonedGraph)
Iterable
objects that hold all the vertices in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
objects that hold all the vertices in the graph. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.startSplitID
- the ID of the starting split.Iterable
object.public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String key)
Iterable
objects that hold all the vertices in the graph matching the specified key. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.key
- the key property nameIterable
object.public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys)
Iterable
objects that hold all the vertices in the graph matching any of the specifed keys described in the vertex filter callback. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.keys
- an array of property keysIterable
object.public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys, boolean bCloneGraph, VertexFilterCallback vfc)
Iterable
objects that hold all the vertices in the graph statisfying the conditions described in the vertex filter callback. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.vfc
- a VertexFilterCallback
object.keys
- an array of property keysIterable
object.public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String[] keys, boolean bCloneGraph, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
objects that hold all the vertices in the graph statisfying the conditions described in the vertex filter callback. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.vfc
- a VertexFilterCallback
object.keys
- an array of property keysIterable
object.public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, String key, boolean bCloneGraph)
Iterable
objects that hold all the vertices in the graph matching the specified key. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.key
- the key property nameIterable
object.public Iterable<Vertex>[] getVerticesPartitioned(org.apache.hadoop.hbase.client.HConnection[] connections, boolean bSkipStoreToCache, int startSplitID, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
objects that hold all the vertices in the graph statisfying the conditions described in the vertex filter callback. Each element in the Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding split. The splits are determined by # of regions & num of splits per region for the table. Note that we assign an integer ID (in the range of [0, N - 1]) to all the splits in the vertex table with N splits. The subset of splits queried will consist of those splits with ID value in the range of [startSplitID, startSplit - 1 + size of connections array].connections
- an array of connections to Apache HBase.bSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.vfc
- a VertexFilterCallback
object.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.Iterable
object.public long getWriteBufferSize()
public boolean isEdgeAutoIndexEnabled(String key)
public boolean isEmpty() throws IOException
IOException
public boolean isVertexAutoIndexEnabled(String key)
public static org.apache.hadoop.conf.Configuration prepareSecureConfig(org.apache.hadoop.conf.Configuration config, String hbaseSecAuth, String hadoopSecAuth, String hmKerberosPrincipal, String rsKerberosPrincipal, String userPrincipal, String keytab)
config
- the HBase configuration objecthbaseSecAuth
- the hbase authentication kerberos/simplehadoopSecAuth
- the hadoop authentication kerberos/simplehmKerberosPrincipal
- The kerberos principal name that should be used to run the HMaster process. The principal name should be in the form: user/hostname@DOMAIN. If "_HOST" is used as the hostname portion, it will be replaced with the actual hostname of the running instance.rsKerberosPrincipal
- Ex. "hbase/_HOST@EXAMPLE.COM".The kerberos principal name that should be used to run the HRegionServer process. The principal name should be in the form: user/hostname@DOMAIN. If _HOST is used as the hostname portion, it will be replaced with the actual hostname of the running instance.userPrincipal
- the user to loginkeytab
- the keytab containing the password of the loginConfiguration
Configuration object.public GraphQuery query()
public static void quietlyClose(org.apache.hadoop.hbase.client.HTable htable)
htable
- the HTable object to close.public static void quietlyClose(org.apache.hadoop.hbase.client.HTableInterface htable)
htable
- the HTable object to close.public void removeAttributeFromAllEdges(EdgeOpCallback eoc)
eoc
- an EdgeOpCallBack object.public void removeAttributeFromAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop)
eoc
- an EdgeOpCallBack object.skipStoreToCache
- if true, the edges instances will not be stored into the cache.dop
- a positive integer defining the number of threads to use when parallel processing the edges.public void removeAttributeFromAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop, ProgressListener pl)
eoc
- an EdgeOpCallBack object.skipStoreToCache
- if true, the edges instances will not be stored into the cache.dop
- a positive integer defining the number of threads to use when parallel processing the edges.pl
- a ProgressListener object.public void removeAttributeFromAllVertices(VertexOpCallback voc)
voc
- a VertexOpCallBack object.public void removeAttributeFromAllVertices(VertexOpCallback voc, boolean skipStoreToCache, int dop)
voc
- a VertexOpCallBack object.skipStoreToCache
- if true, the vertices instances will not be stored into the cache.dop
- a positive integer defining the number of threads to use when parallel processing the vertices.public void removeAttributeFromAllVertices(VertexOpCallback voc, boolean skipStoreToCache, int dop, ProgressListener pl)
voc
- a VertexOpCallBack object.skipStoreToCache
- if true, the vertices instances will not be stored into the cache.dop
- a positive integer defining the number of threads to use when parallel processing the vertices.pl
- a ProgressListener object.public void removeEdge(Edge edge)
public void removeVertex(Vertex vertex)
public void rollback()
public static byte[] saltEdge(byte[] ba)
ba
- the edge ID represented as a byte arraypublic static byte[] saltVertex(byte[] ba)
ba
- the vertex ID represented as a byte arraypublic static String serializableToStr(Serializable seri) throws IOException
seri
- an object of Serializable type. It must not be null.IOException
public void setBatchSize(int batchsize)
batchsize
- the size of the batch used for update operations.public void setCompression(String compress)
compress
- the compression used in the property graph tablespublic void setDataBlockEncoding(org.apache.hadoop.hbase.io.encoding.DataBlockEncoding dbe)
dbe
- the data block encoding used in the property graph tablespublic void setDefaultEdgeOptFlag(OraclePropertyGraphBase.OptimizationFlag eof)
eof
- an OptimizationFlag object to be set to this property graphpublic void setDefaultIndexParameters(OracleIndexParameters indexParams)
setDefaultIndexParameters
in class OraclePropertyGraphBase
indexParams
- a OracleIndexParameters
object.public void setDefaultVertexOptFlag(OraclePropertyGraphBase.OptimizationFlag vof)
vof
- an OptimizationFlag objectpublic void setEdgeBlockCacheSize(int blockCSize)
blockCSize
- a positive integer representing the size of the block cache (in bytes) used in the vertex table. Default value set to 131072 bytes.public void setEdgeFilterCallback(EdgeFilterCallback efc)
efc
- a EdgeFilterCallback
object to be set to this property graphpublic void setEdgeInitialNumRegions(int numRegions)
numRegions
- a positive integer with the initial number of regions for edge table. Default value set to 4public void setEdgeSndIndexBlockCacheSize(int blockCSize)
blockCSize
- a positive integer representing the size of the block cache (in bytes) used in the vertex table. Default value set to 131072 bytes.public void setEdgeSndIndexWriteBufferSize(long writebuffer)
writebuffer
- the size of the write buffer used in the edge secondary index tablepublic void setEdgeWriteBufferSize(long writebuffer)
writebuffer
- the maximum size of the write buffer used in the edge tablepublic void setIndexLuceneWriteBufferSize(long writebuffer)
writebuffer
- the maximum size of the write buffer used in the index tablepublic void setInitialNumRegions(int numRegions)
numRegions
- the initial number of regions.public void setLuceneBlockCacheSize(int blockCSize)
blockCSize
- a positive integer representing the size of the block cache (in bytes) used in the vertex table. Default value set to 131072 bytes.public void setNumSplitsPerRegion(int iNumSplitsPerRegion)
iNumSplitsPerRegion
- a positive integer specifying the number of splits per region to use when scanning vertices/edges. Default value set to 1.public void setProgressListener(ProgressListener pl)
pl
- a ProgressListener object.public void setQueueSize(int size)
size
- the size of the queuepublic void setScanCachingSize(int iScanCachingSize)
iScanCachingSize
- the cache size to use.public void setVertexBlockCacheSize(int blockCSize)
blockCSize
- a positive integer representing the size of the block cache (in bytes) used in the vertex table. This is a meta data operation, so changes to this setting will show after clearing the repository and recreating the vertex tables. Default value set to 131072 bytes.public void setVertexFilterCallback(VertexFilterCallback vfc)
vfc
- a VertexFilterCallback
object to be set to this property graphpublic void setVertexInitialNumRegions(int numRegions)
numRegions
- a positive integer with the initial number of regions for vertex table. Default value set to 4public void setVertexSndIndexBlockCacheSize(int blockCSize)
blockCSize
- a positive integer representing the size of the block cache (in bytes) used in the vertex table. Default value set to 131072 bytes.public void setVertexSndIndexWriteBufferSize(long writebuffer)
writebuffer
- the maximum size of the write buffer used in the vertex secondary index tablepublic void setVertexWriteBufferSize(long writebuffer)
writebuffer
- the maximum size of the write buffer used in the vertex tablepublic void setWriteBufferSize(long writebuffer)
writebuffer
- the maximum size of the write buffer used in the vertex tablepublic void shutdown()
public void startTransaction()
public void stopTransaction(TransactionalGraph.Conclusion conclusion)
public static Object strToSerializable(String s) throws IOException
s
- String representation of a Java Serializable object. It MUST not be null.IOException
Copyright © 2015 Oracle and/or its affiliates. All Rights Reserved.