oracle.pg.nosql

Class OraclePropertyGraph

java.lang.Object

oracle.pg.common.OraclePropertyGraphBase

oracle.pg.nosql.OraclePropertyGraph

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, oracle.pg.common.messages.MesgConsts, OracleCSVDatatypeConstants, OracleGraphAttributeUpdater, OracleIndexableGraph, OracleMessageConstants, OracleMetadataGraph, OraclePropertyGraphConstants, OraclePropertyGraphDatatypeConstants, org.apache.tinkerpop.gremlin.structure.Graph, org.apache.tinkerpop.gremlin.structure.util.Host

public class OraclePropertyGraph
extends OraclePropertyGraphBase

This class implements the Blueprints Graph interface on top of a supported backend database. Note that this implementation is not thread safe. To safely perform concurrent operations against a single graph, multiple instances of OraclePropertyGraph are recommended.

Nested Class Summary

Nested classes/interfaces inherited from class oracle.pg.common.OraclePropertyGraphBase

OraclePropertyGraphBase.CacheStatus, OraclePropertyGraphBase.OptimizationFlag

Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.structure.Graph

org.apache.tinkerpop.gremlin.structure.Graph.Exceptions, org.apache.tinkerpop.gremlin.structure.Graph.Features, org.apache.tinkerpop.gremlin.structure.Graph.Hidden, org.apache.tinkerpop.gremlin.structure.Graph.OptIn, org.apache.tinkerpop.gremlin.structure.Graph.OptIns, org.apache.tinkerpop.gremlin.structure.Graph.OptOut, org.apache.tinkerpop.gremlin.structure.Graph.OptOuts, org.apache.tinkerpop.gremlin.structure.Graph.Variables

Nested classes/interfaces inherited from interface oracle.pg.common.OraclePropertyGraphConstants

OraclePropertyGraphConstants.QueueAction

Field Summary

Fields inherited from interface org.apache.tinkerpop.gremlin.structure.Graph

GRAPH

Fields inherited from interface oracle.pg.common.OracleMessageConstants

MG_ERR_USER_REQ_OP_CANCEL, MSG_E_AUTO_IDX_MUST_SOLR_OR_LUCENE, MSG_E_AUTO_IDX_NOT_EXIST, MSG_ERR_ARG_CANNOT_BE_NULL, MSG_ERR_ID_CANNOT_BE_NULL, MSG_ERR_NO_ELEM_TO_BE_CONSUMED, MSG_ERR_NO_OP_SUPPORTED, MSG_IDX_KEY_NOT_NULL, MSG_IDX_KEYS_NOT_NULL, MSG_TXT_IDX_NOT_FOUND, MSG_V_AUTO_IDX_MUST_SOLR_OR_LUCENE, MSG_V_AUTO_IDX_NOT_EXIST

Fields inherited from interface oracle.pg.common.messages.MesgConsts

ERR_ARG_CANNOT_BE_NULL, ERR_CODE_NOT_IN_LIST, ERR_DOP_CONSTRAINT, ERR_E_AUTO_IDX_MUST_SOLR_OR_LUCENE, ERR_E_AUTO_IDX_NOT_EXIST, ERR_E_DS_MUSTBE_FILE_OR_IS, ERR_E_MAX_LINE_CONSTRAINT, ERR_EDGE_DIR_NOT_BOTH, ERR_EDGE_WORK_TBL_NOT_CLEAN, ERR_GRAPH_NAME_CANT_BENULL, ERR_HIT_EXCEPTION, ERR_HIT_INTERRUPT, ERR_HIT_IO, ERR_HIT_OPGE, ERR_HIT_PARSEE, ERR_ID_CANNOT_BE_NULL, ERR_IDX_KEY_CANNOT_BE_NULL, ERR_IDX_KEY_NOT_NULL, ERR_IDX_KEYS_NOT_NULL, ERR_IN_DS_EDGE_CANTBE_NULL, ERR_IN_DS_VERT_CANTBE_NULL, ERR_IN_E_FLAT_DOESNT_EXIST, ERR_IN_V_FLAT_DOESNT_EXIST, ERR_INPUT_LIST_NOT_NULL, ERR_INPUT_NOT_NULL, ERR_INVALID_CHANGE_ACTION, ERR_INVALID_NUM_FIELDS, ERR_INVALID_NUM_NOARG, ERR_INVALID_NUMBER, ERR_INVALID_VAL, ERR_KEY_CANNOT_BE_ID, ERR_KEY_CANNOT_BE_NULL, ERR_KEY_CANNOT_BE_NULL_EMPTY, ERR_KEY_NOT_SET_TO, ERR_NO_ELEM_TO_BE_CONSUMED, ERR_NO_OP_SUPPORTED, ERR_NOT_IMPLEMENTED_YET, ERR_NOT_ORACLE_V_E, ERR_NUM_PART_CONSTRAINT, ERR_OFFSET_CONSTRAINT, ERR_OFFSET_E_MUST_BE_POS, ERR_OFFSET_V_MUST_BE_POS, ERR_OPT_FLAG_EDGE_INVALID, ERR_OPT_FLAG_VERT_INVALID, ERR_ORA_TEXT_INVALID_KEY, ERR_ORA_TEXT_ONLY_AUTO, ERR_OUTPUT_LIST_NOT_NULL, ERR_PG_ALREADY_EXISTS, ERR_PG_NOT_EMPTY, ERR_PG_NOT_NULL, ERR_SIZE_MUST_BE_POS, ERR_TIMEOUT_TAB_CREATION, ERR_TXT_IDX_NOT_FOUND, ERR_TYPE_ID_NOT_RECO, ERR_UNSUPPORTED_VAL_TYP, ERR_USER_REQ_OP_CANCEL, ERR_V_AUTO_IDX_MUST_SOLR_OR_LUCENE, ERR_V_AUTO_IDX_NOT_EXIST, ERR_V_DS_MUSTBE_FILE_OR_IS, ERR_V_MAX_LINE_CONSTRAINT, ERR_VALUE_CANNOT_BE_NULL, INFO_EMP_K_NO_P_VAL, INFO_NUL_K_NO_P_VAL

Fields inherited from interface oracle.pg.common.OraclePropertyGraphConstants

VERTEX_LABEL

Fields inherited from interface oracle.pg.common.OracleCSVDatatypeConstants

CSV_DATE_TIME_FORMATS, CSV_DT_KEYWORD_BOOLEAN, CSV_DT_KEYWORD_BYTE, CSV_DT_KEYWORD_CHAR, CSV_DT_KEYWORD_DATE, CSV_DT_KEYWORD_DOUBLE, CSV_DT_KEYWORD_FLOAT, CSV_DT_KEYWORD_INTEGER, CSV_DT_KEYWORD_JSON, CSV_DT_KEYWORD_LONG, CSV_DT_KEYWORD_RDF, CSV_DT_KEYWORD_SHORT, CSV_DT_KEYWORD_SPATIAL, CSV_DT_KEYWORD_STRING, OPG_DATETIME_FORMAT

Fields inherited from interface oracle.pg.common.OraclePropertyGraphDatatypeConstants

TYPE_DT_BOOL, TYPE_DT_BYTE, TYPE_DT_CHAR, TYPE_DT_DATE, TYPE_DT_DOUBLE, TYPE_DT_EMPTY, TYPE_DT_FLOAT, TYPE_DT_INTEGER, TYPE_DT_JSON, TYPE_DT_LONG, TYPE_DT_SERI, TYPE_DT_SHORT, TYPE_DT_SPATIAL, TYPE_DT_STRING, TYPE_DT_URI

Method Summary

Modifier and Type	Method and Description
org.apache.tinkerpop.gremlin.structure.Edge	addEdge(java.lang.Object id, org.apache.tinkerpop.gremlin.structure.Vertex outVertex, org.apache.tinkerpop.gremlin.structure.Vertex inVertex, java.lang.String label) This method adds an edge to the graph instance.
org.apache.tinkerpop.gremlin.structure.Vertex	addVertexById(java.lang.Object id) This method adds an vertex to the graph instance.
void	clearRepository() This method removes all vertices and edges from this property graph instance.
void	close() A shutdown function is required to properly close the graph.
void	closeKVStore() This method closes the underlying KVStore instance
void	commit() Commit changes done to this property graph instace.
long	countEdges(int dop, ProgressListener pl) Counts all Edges using parallel scan with dop threads
long	countVertices(int dop, ProgressListener pl) Counts all vertices using parallel scan with dop threads
void	createGraphTables() This method creates the vertex, edge, and index metadata tables for a property graph
void	createIndexTable() This method creates the index metadata tables for a property graph
void	dispose() Closes the graph without commiting any changes
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>	edgesByProperty(java.lang.String key, java.lang.Object value, java.lang.Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery) Return an iterable to all matching edges that have a particular key/value property.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>	edgesByPropertyKey(java.lang.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 specified edge filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID) Gets an array of Iterable objects that hold all the edges in the graph.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int iStartSplitID, boolean bOptimizedSplits, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag) Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int startSplitID, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag) Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String key) Gets an array of Iterable objects that hold all the edges in the graph that have a particular key.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys) Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys, EdgeFilterCallback efc) Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag) Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesWithCustomizedParallelTableScan(java.lang.String[] keys) Return an Iterable to all the edges in the graph that have any of the specified keys.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[]	edgesWithCustomizedParallelTableScan(java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag) Return an Iterable to all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>	edgesWithDefaultParallelTableScan(java.lang.String[] keys) Return an Iterable to all the edges in the graph that have any of the specified keys.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>	edgesWithDefaultParallelTableScan(java.lang.String[] keys, EdgeFilterCallback efc) Return an Iterable to all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>	edgesWithDefaultParallelTableScan(java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag) Return an Iterable to all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.
org.apache.tinkerpop.gremlin.structure.Graph.Features	features() Gets the particular features of the graph implementation for Tinkerpop 3
void	flushUpdates() Flushes updates into the pertinent HBase tables.
int	getClearTableDOP() Returns the number of workers used when removing all data from a table
int	getClearTablePKBufferSize() Returns the size of the primary key buffer used when removing all data from a table
int	getClearTableThreadsPerWorker() Returns the number of threads per clear table worker used when removing all rows from a table
int	getCustomizedParallelScanDOP() Get the dop used for parallel scan
int	getDOPForMetadataOperations()
OracleEdge	getEdge(java.lang.Object id) Return the edge referenced by the object identifier.
OracleEdgeBase	getEdgeInstance(java.lang.Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache) Returns an instance of OracleEdgeBase.
OracleEdgeBase	getEdgeInstance(OracleVertexBase outVertex, OracleVertexBase inVertex, java.lang.String edgeLabel, java.lang.Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache) Returns an instance of OracleEdgeBase.
int	getEdgePropertyNames(int dop, int timeout, java.util.Map<java.lang.String,java.lang.Class> propertyNames, ProgressListener pl) Gets the property names of all edges using parallel scans and the specified DOP.
int	getEdgePropertyNames(int dop, int timeout, java.util.Set<java.lang.String> propertyNames, ProgressListener pl) Gets the property names of all edges using parallel scans and the specified DOP.
int	getEdgeTableSplits() Get the number of Edge table splits used for parallel scans in the edge table.
java.lang.String	getEdgeTabName() Get the name of the Oracle NoSQL Database table used to store edges in this property graph.
static OraclePropertyGraph	getInstance(oracle.kv.KVStoreConfig kvconfig, java.lang.String szGraphName) Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
static OraclePropertyGraph	getInstance(oracle.kv.KVStoreConfig kvconfig, java.lang.String szGraphName, oracle.kv.LoginCredentials lc) Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
static OraclePropertyGraph	getInstance(oracle.kv.KVStoreConfig kvconfig, java.lang.String szGraphName, java.lang.String username, java.lang.String password) Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
static OraclePropertyGraph	getInstance(oracle.kv.KVStoreConfig kvconfig, java.lang.String szGraphName, java.lang.String username, java.lang.String password, java.util.Properties secProperties) Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
static OraclePropertyGraph	getInstance(oracle.kv.KVStoreConfig kvconfig, java.lang.String szGraphName, java.lang.String username, java.lang.String password, java.lang.String trustStoreFile) Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
static OraclePropertyGraph	getInstance(oracle.kv.KVStore kvStore, oracle.kv.KVStoreConfig kvConfig, java.lang.String graphName)
static OraclePropertyGraph	getInstance(PgNosqlGraphConfig config) Returns an instance of OraclePropertyGraph using a PGX PgNosqlGraphConfig object.
static OraclePropertyGraph	getInstance(java.lang.String storeName, java.lang.String host, int port, java.lang.String szGraphName) Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
java.util.Set<java.lang.Long>	getInvalidEdgeIDSet(int dop, ProgressListener pl) Gets a set of invalid edges that are stored in the property graph.
oracle.kv.KVStoreConfig	getKVStoreConfig() Get the KVStoreConfig object associated with the backend database
static oracle.kv.KVStoreConfig	getKVStoreConfig(PgNosqlGraphConfig config) Gets an KVStoreConfig from a PGX PgNosqlGraphConfig object
oracle.kv.LoginCredentials	getLoginCredentials()
long	getMaxEdgeID(int dop, ProgressListener pl) Get the maximum edge ID using parallel scan and the specified DOP.
long	getMaxVertexID(int dop, ProgressListener pl) Get maximum vertex ID using parallel scans and the specified DOP.
long	getMinEdgeID(int dop, ProgressListener pl) Get the minimum edge ID using parallel scan with dop threads
long	getMinVertexID(int dop, ProgressListener pl) Get minimum vertex ID using parallel scans and the specified DOP.
long	getOperationQueueSize() Get the size of the operation queue
OracleIndexManager	getOracleIndexManager() Gets the Oracle PropertyGraphIndex Manager associated to this property graph instance.
oracle.kv.table.TableIteratorOptions	getTableIteratorOptions() Gets the TableIteratorOptions object associated to this property graph
OracleVertex	getVertex(java.lang.Object id) Return the vertex referenced by the object identifier.
java.util.Set<java.lang.Long>	getVertexIDSet(int dop, ProgressListener pl) Gets a set of Vertex IDs that are stored in the property graph
OracleVertexBase	getVertexInstance(java.lang.Long vid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache) Returns an instance of OracleVertexBase.
int	getVertexPropertyNames(int dop, int timeout, java.util.Map<java.lang.String,java.lang.Class> propertyNames, ProgressListener pl) Gets the property names of all vertices using parallel scans and the specified DOP.
int	getVertexPropertyNames(int dop, int timeout, java.util.Set<java.lang.String> propertyNames, ProgressListener pl) Gets the property names of all vertices using parallel scans and the specified DOP.
int	getVertexTableSplits() Get the number of Vertex table splits used for parallel scans in the vertex table.
java.lang.String	getVertexTabName() Get the name of the Oracle NoSQL Database table used to store vertices in this property graph.
void	removeEdge(org.apache.tinkerpop.gremlin.structure.Edge edge) Remove the provided edge from the graph
void	removeVertex(org.apache.tinkerpop.gremlin.structure.Vertex vertex) Remove the provided vertex from the graph
void	setClearTableDOP(int dop) Sets the number of workers to be used when removing all rows from a table
void	setClearTablePKBufferSize(int size) Set the size of the primary key buffer used when removing all rows from a table
void	setClearTableThreadsPerWorker(int threads) Sets the number of threads per clear table worker to be used when removing all rows from a table
void	setCustomizedParallelScanDOP(int iDOP) Set the dop used for parallel scan
void	setTableIteratorOptions(oracle.kv.table.TableIteratorOptions tio) Sets the TableIteratorOptions object associated to this property graph
<T extends org.apache.tinkerpop.gremlin.structure.Element> void	updateGraph(OpCallback<T> oc, boolean skipStoreToCache, int dop, ProgressListener pl, OpCallback.UpdateType updateType) Updates a graph based on the specified OpCallback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>	verticesByProperty(java.lang.String key, java.lang.Object value, java.lang.Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery) Return an iterable to all matching vertices that have a particular key/value property.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>	verticesByPropertyKey(java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag) Return an Iterable to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID) Gets an array of Iterable objects that hold all the vertices in the graph.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int iStartSplitID, boolean bOptimizedSplits, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag) Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int startSplitID, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag) Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String key) Gets an array of Iterable objects that hold all the vertices in the graph that have a particular key.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys) Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys, VertexFilterCallback vfc) Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag) Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesWithCustomizedParallelTableScan(java.lang.String[] keys) Return an Iterable to all the vertices in the graph that have any of the specified keys.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[]	verticesWithCustomizedParallelTableScan(java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag) Return an Iterable to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>	verticesWithDefaultParallelTableScan(java.lang.String[] keys) Return an Iterable to all the vertices in the graph that have any of the specified keys.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>	verticesWithDefaultParallelTableScan(java.lang.String[] keys, VertexFilterCallback vfc) Return an Iterable to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.
java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>	verticesWithDefaultParallelTableScan(java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag) Return an Iterable to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.

Methods inherited from class oracle.pg.common.OraclePropertyGraphBase

addUpdatedEdge, addUpdatedVertex, addVertex, addVertex, adjacentEdgesFromVertices, adjacentEdgesFromVertices, clearCache, clearUpdateQueue, commitIndices, compute, compute, configuration, createIndex, decodeObject, edges, edges, edgesByIds, edgesByIds, edgesByProperty, edgesByProperty, edgesByProperty, edgesByProperty, edgesByPropertyKey, edgesByPropertyKey, edgesByPropertyKey, getBatchSize, getCacheStatus, getConfig, getDatatypeClassFromValueObjForTextIndex, getDateTimeFormatter, getDefaultEdgeOptFlag, getDefaultIndexParameters, getDefaultVertexOptFlag, getEdgeFilterCallback, getElementsProperties, getGraphName, getJustEdgeIdOptFlag, getJustVertexIdOptFlag, getMaxLabelLengthAllowedInBytes, getMaxPropertyNameLengthAllowedInBytes, getMaxValueLengthAllowedInBytes, getProgressListener, getQueueSize, getShortestPath, getShortestPath, getSimpleDateFormat, getStringForObj, getTextIndexDirectoryPrefix, getVertexFilterCallback, io, isBuiltinElementsCacheDisabled, isDisposed, isEmpty, isShutdown, isSkipRefreshIndicesEnabled, isTransientPropertyGraphInstance, removeEdges, removeEdges, removeEdges, removeEdges, removeVertices, removeVertices, removeVertices, removeVertices, rollback, serializableToStr, setBatchSize, setCacheStatus, setDefaultEdgeOptFlag, setDefaultIndexParameters, setDefaultVertexOptFlag, setEdgeFilterCallback, setProgressListener, setQueueSize, setSkipRefreshIndices, setSolrJavaBinFormat, setTransientPropertyGraphInstance, setVertexFilterCallback, startTransaction, strToSerializable, sum, supportVertexLabels, toString, traversal, traversal, tx, useSolrJavaBinFormat, variables, vertices, vertices, verticesByIds, verticesByIds, verticesByProperty, verticesByProperty, verticesByProperty, verticesByProperty, verticesByPropertyKey, verticesByPropertyKey, verticesByPropertyKey

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.tinkerpop.gremlin.structure.Graph

addVertex

Methods inherited from interface org.apache.tinkerpop.gremlin.structure.util.Host

getHostingVertex

Methods inherited from interface oracle.pg.common.OracleIndexableGraph

createKeyIndex, createKeyIndex, createKeyIndex, dropAllAutoIndices, dropAllIndices, dropAllManualIndices, dropIndex, dropKeyIndex, dropKeyIndex, dropKeyIndex, edgesUsingTextSearch, getAutoIndex, getIndex, getIndexedKeys, getIndexParameters, getIndices, isEdgeAutoIndexEnabled, isVertexAutoIndexEnabled, refreshAutoIndices, validateIndexManager, verticesUsingTextSearch

Methods inherited from interface oracle.pg.common.OracleMetadataGraph

countEdges, countEdges, countVertices, countVertices, getEdgePropertyNames, getEdgePropertyNames, getElementsProperties, getInvalidEdgeIDSet, getInvalidEdgeIDSet, getMaxEdgeID, getMaxEdgeID, getMaxVertexID, getMaxVertexID, getMinEdgeID, getMinEdgeID, getMinVertexID, getMinVertexID, getVertexIDSet, getVertexIDSet, getVertexPropertyNames, getVertexPropertyNames

Methods inherited from interface oracle.pg.common.OracleGraphAttributeUpdater

addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllVertices, addAttributeToAllVertices, addAttributeToAllVertices, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllVertices, removeAttributeFromAllVertices, removeAttributeFromAllVertices

Method Detail

addEdge

public org.apache.tinkerpop.gremlin.structure.Edge addEdge(java.lang.Object id,
                                                           org.apache.tinkerpop.gremlin.structure.Vertex outVertex,
                                                           org.apache.tinkerpop.gremlin.structure.Vertex inVertex,
                                                           java.lang.String label)

This method adds an edge to the graph instance. Note that this is just a logical operation. Note that this is not a thread safe method.

Specified by:

addEdge in class OraclePropertyGraphBase

Parameters:

id - the id of the edge

outVertex - has to be of type OracleVertex

inVertex - has to be of type OracleVertex

label - edge label

Returns:

an OracleEdge object.

addVertexById

public org.apache.tinkerpop.gremlin.structure.Vertex addVertexById(java.lang.Object id)

This method adds an vertex to the graph instance. Note that this is just a logical operation. Note that this is not a thread safe method.

Specified by:

addVertexById in class OraclePropertyGraphBase

Parameters:

id - the id of the vertex

Returns:

an OracleVertex object.

clearRepository

public void clearRepository()
                     throws java.lang.Exception

This method removes all vertices and edges from this property graph instance. Additionally, all existing index are removed from this property graph instance. A DDL (truncate) is executed so there is no way to rollback.

Specified by:

clearRepository in class OraclePropertyGraphBase

Throws:

java.lang.Exception

close

public void close()

A shutdown function is required to properly close the graph.

closeKVStore

public void closeKVStore()

This method closes the underlying KVStore instance

commit

public void commit()

Commit changes done to this property graph instace.

Specified by:

commit in class OraclePropertyGraphBase

countEdges

public long countEdges(int dop,
                       ProgressListener pl)

Counts all Edges using parallel scan with dop threads

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the edges.

pl - a ProgressListener object.

Returns:

number of edges in the graph

countVertices

public long countVertices(int dop,
                          ProgressListener pl)

Counts all vertices using parallel scan with dop threads

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the vertices.

pl - a ProgressListener object.

Returns:

number of vertices in the graph

createGraphTables

public void createGraphTables()
                       throws java.lang.Exception

This method creates the vertex, edge, and index metadata tables for a property graph

Throws:

java.lang.Exception

createIndexTable

public void createIndexTable()
                      throws java.lang.Exception

This method creates the index metadata tables for a property graph

Throws:

java.lang.Exception

dispose

public void dispose()

Closes the graph without commiting any changes

edgesByProperty

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesByProperty(java.lang.String key,
                                                                                       java.lang.Object value,
                                                                                       java.lang.Class dtClass,
                                                                                       boolean acceptWildcard,
                                                                                       boolean preferredLuceneQuery)

Return an iterable to all matching edges that have a particular key/value property. When an automatic text index on the given key is absent, a full table scan will be carried out to find matching edges.

Specified by:

edgesByProperty in class OraclePropertyGraphBase

Parameters:

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 object.

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.

edgesByPropertyKey

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesByPropertyKey(java.lang.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 specified edge filter callback. The information read back from the edges will be complete or partial based on the optimization flag specified.

Specified by:

edgesByPropertyKey in class OraclePropertyGraphBase

Parameters:

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.

edgesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                          boolean bSkipStoreToCache,
                                                                                          int startSplitID)

Gets an array of 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 total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the edges instances will not be stored into the cache.

startSplitID - the ID of the starting split.

Returns:

an Iterable array object.

edgesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                          boolean bSkipStoreToCache,
                                                                                          int iTotalSplits,
                                                                                          int iStartSplitID,
                                                                                          boolean bOptimizedSplits,
                                                                                          java.lang.String[] keys,
                                                                                          EdgeFilterCallback efc,
                                                                                          OraclePropertyGraphBase.OptimizationFlag optFlag)

Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback. The information read back from the edges will be complete or partial based on the optimization flag specified. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. 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 [iStartSplitID, iStartSplit - 1 + size of connections array].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the edges instances will not be stored into the cache.

iTotalSplits - the total number of splits

iStartSplitID - the ID of the starting split.

bOptimizedSplits - the flag showing if using optimized splits

keys - an array of property key names. It can be NULL which implies all edges in the graph will be returned.

efc - a EdgeFilterCallback object specifying the conditions to keep an edge in the Iterable.

optFlag - 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.

Returns:

an Iterable array object.

edgesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                          boolean bSkipStoreToCache,
                                                                                          int iTotalSplits,
                                                                                          int startSplitID,
                                                                                          java.lang.String[] keys,
                                                                                          EdgeFilterCallback efc,
                                                                                          OraclePropertyGraphBase.OptimizationFlag optFlag)

Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback. The information read back from the edges will be complete or partial based on the optimization flag specified. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the edges instances will not be stored into the cache.

iTotalSplits - the total number of splits

startSplitID - the ID of the starting split.

keys - an array of property key names. It can be NULL which implies all edges in the graph will be returned.

efc - a EdgeFilterCallback object specifying the conditions to keep an edge in the Iterable.

optFlag - 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.

Returns:

an Iterable array object.

edgesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                          boolean bSkipStoreToCache,
                                                                                          int startSplitID,
                                                                                          java.lang.String key)

Gets an array of Iterable objects that hold all the edges in the graph that have a particular key. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. The total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the edges instances will not be stored into the cache.

startSplitID - the ID of the starting split.

key - name of the property. It can be NULL which implies all edges in the graph will be returned.

Returns:

an Iterable array object.

edgesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                          boolean bSkipStoreToCache,
                                                                                          int startSplitID,
                                                                                          java.lang.String[] keys)

Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. The total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the edges instances will not be stored into the cache.

startSplitID - the ID of the starting split.

keys - an array of property key names. It can be NULL which implies all edges in the graph will be returned.

Returns:

an Iterable array object.

edgesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                          boolean bSkipStoreToCache,
                                                                                          int startSplitID,
                                                                                          java.lang.String[] keys,
                                                                                          EdgeFilterCallback efc)

Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys and satisfy the specified edge 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 total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the edges instances will not be stored into the cache.

startSplitID - the ID of the starting split.

keys - an array of property key names. It can be NULL which implies all edges in the graph will be returned.

efc - a EdgeFilterCallback object specifying the conditions to keep an edge in the Iterable.

Returns:

an Iterable array object.

edgesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                          boolean bSkipStoreToCache,
                                                                                          int startSplitID,
                                                                                          java.lang.String[] keys,
                                                                                          EdgeFilterCallback efc,
                                                                                          OraclePropertyGraphBase.OptimizationFlag optFlag)

Gets an array of Iterable objects that hold all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback. The information read back from the edges will be complete or partial based on the optimization flag specified. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. The total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the edges instances will not be stored into the cache.

startSplitID - the ID of the starting split.

keys - an array of property key names. It can be NULL which implies all edges in the graph will be returned.

efc - a EdgeFilterCallback object specifying the conditions to keep an edge in the Iterable.

optFlag - 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.

Returns:

an Iterable array object.

edgesWithCustomizedParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesWithCustomizedParallelTableScan(java.lang.String[] keys)

Return an Iterable to all the edges in the graph that have any of the specified keys.

Parameters:

keys - an array of property key names. It can be NULL which implies all edges in the graph will be returned.

edgesWithCustomizedParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge>[] edgesWithCustomizedParallelTableScan(java.lang.String[] keys,
                                                                                                              EdgeFilterCallback efc,
                                                                                                              OraclePropertyGraphBase.OptimizationFlag optFlag)

Return an Iterable to all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback. The information read back from the edges will be complete or partial based on the optimization flag specified.

Parameters:

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.

optFlag - 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.

edgesWithDefaultParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesWithDefaultParallelTableScan(java.lang.String[] keys)

Return an Iterable to all the edges in the graph that have any of the specified keys.

Parameters:

keys - an array of property key names. It can be NULL which implies all edges in the graph will be returned.

edgesWithDefaultParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesWithDefaultParallelTableScan(java.lang.String[] keys,
                                                                                                         EdgeFilterCallback efc)

Return an Iterable to all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.

Parameters:

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.

edgesWithDefaultParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Edge> edgesWithDefaultParallelTableScan(java.lang.String[] keys,
                                                                                                         EdgeFilterCallback efc,
                                                                                                         OraclePropertyGraphBase.OptimizationFlag optFlag)

Return an Iterable to all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback. The information read back from the edges will be complete or partial based on the optimization flag specified.

Parameters:

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.

optFlag - 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.

features

public org.apache.tinkerpop.gremlin.structure.Graph.Features features()

Gets the particular features of the graph implementation for Tinkerpop 3

flushUpdates

public void flushUpdates()

Flushes updates into the pertinent HBase tables.

Overrides:

flushUpdates in class OraclePropertyGraphBase

getClearTableDOP

public int getClearTableDOP()

Returns the number of workers used when removing all data from a table

Returns:

the degree of parallelism used when removing all rows from a table

getClearTablePKBufferSize

public int getClearTablePKBufferSize()

Returns the size of the primary key buffer used when removing all data from a table

Returns:

buffer size

getClearTableThreadsPerWorker

public int getClearTableThreadsPerWorker()

Returns the number of threads per clear table worker used when removing all rows from a table

Returns:

the number of threads per clear table worker used when removing all rows from a table

getCustomizedParallelScanDOP

public int getCustomizedParallelScanDOP()

Get the dop used for parallel scan

getDOPForMetadataOperations

public int getDOPForMetadataOperations()

getEdge

public OracleEdge getEdge(java.lang.Object id)

Return the edge referenced by the object identifier.

Specified by:

getEdge in class OraclePropertyGraphBase

Parameters:

id - the object identifier of the referenced edge

Returns:

an OracleEdge object

getEdgeInstance

public OracleEdgeBase getEdgeInstance(java.lang.Long eid,
                                      boolean bCreateIfAbsentFromCache,
                                      boolean bSkipStoreToCache)

Returns an instance of OracleEdgeBase. If there is no match in the cache and bCreateIfAbsentFromCache is false, then a NULL value will be returned. If the skipStoreToCache is true, then the vertex will not be stored into the cache.

Specified by:

getEdgeInstance in class OraclePropertyGraphBase

Parameters:

eid - the id of the edge

bCreateIfAbsentFromCache - if false, returns a NULL value if there is no match in the cache.

bSkipStoreToCache - if true, the vertex instance will not be stored into the cache.

Returns:

a OracleEdgeBase object.

getEdgeInstance

public OracleEdgeBase getEdgeInstance(OracleVertexBase outVertex,
                                      OracleVertexBase inVertex,
                                      java.lang.String edgeLabel,
                                      java.lang.Long eid,
                                      boolean bCreateIfAbsentFromCache,
                                      boolean bSkipStoreToCache)

Returns an instance of OracleEdgeBase. If there is no match in the cache and bCreateIfAbsentFromCache is false, then a NULL value will be returned. If the skipStoreToCache is true, then the vertex will not be stored into the cache.

Specified by:

getEdgeInstance in class OraclePropertyGraphBase

Parameters:

eid - the id of the edge

outVertex - the outgoing Vertex of the edge

inVertex - the incoming Vertex of the edge

edgeLabel - the label for the Edge.

bCreateIfAbsentFromCache - if false, returns a NULL value if there is no match in the cache.

bSkipStoreToCache - if true, the vertex instance will not be stored into the cache.

Returns:

a OracleEdgeBase object.

getEdgePropertyNames

public int getEdgePropertyNames(int dop,
                                int timeout,
                                java.util.Map<java.lang.String,java.lang.Class> propertyNames,
                                ProgressListener pl)

Gets the property names of all edges using parallel scans and the specified DOP.

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the edges

timeout - time out in the unit of seconds

propertyNames - a map of vertex

pl - a ProgressListener object.

getEdgePropertyNames

public int getEdgePropertyNames(int dop,
                                int timeout,
                                java.util.Set<java.lang.String> propertyNames,
                                ProgressListener pl)

Gets the property names of all edges using parallel scans and the specified DOP.

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the edges

timeout - time out in the unit of seconds

propertyNames - a set of property names to be returned

pl - a ProgressListener object.

getEdgeTableSplits

public int getEdgeTableSplits()

Get the number of Edge table splits used for parallel scans in the edge table.

Returns:

the number of splits in the edge table

Throws:

java.io.IOException

getEdgeTabName

public java.lang.String getEdgeTabName()

Get the name of the Oracle NoSQL Database table used to store edges in this property graph.

Returns:

the edge table name.

getInstance

public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig,
                                              java.lang.String szGraphName)
                                       throws java.lang.Exception

Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.

Parameters:

kvconfig - a KVStoreConfig object

szGraphName - name of the property graph to be created

Returns:

an OraclePropertyGraph object

Throws:

java.lang.Exception

getInstance

public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig,
                                              java.lang.String szGraphName,
                                              oracle.kv.LoginCredentials lc)
                                       throws java.lang.Exception

Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.

Parameters:

kvconfig - a KVStoreConfig object

szGraphName - name of the property graph to be created

lc - a LoginCredentials object that can be used to authenticate a user

Returns:

an OraclePropertyGraph object

Throws:

java.lang.Exception

getInstance

public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig,
                                              java.lang.String szGraphName,
                                              java.lang.String username,
                                              java.lang.String password)
                                       throws java.lang.Exception

Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.

Parameters:

kvconfig - a KVStoreConfig object

szGraphName - name of the property graph to be created

username - name of the user

password - password of the user

Returns:

an OraclePropertyGraph object

Throws:

java.lang.Exception

getInstance

public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig,
                                              java.lang.String szGraphName,
                                              java.lang.String username,
                                              java.lang.String password,
                                              java.util.Properties secProperties)
                                       throws java.lang.Exception

Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.

Parameters:

kvconfig - a KVStoreConfig object

szGraphName - name of the property graph to be created

username - name of the user

password - password of the user

secProperties - a Properties object that defines the KVStoreConfig security settings

Returns:

an OraclePropertyGraph object

Throws:

java.lang.Exception

getInstance

public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig,
                                              java.lang.String szGraphName,
                                              java.lang.String username,
                                              java.lang.String password,
                                              java.lang.String trustStoreFile)
                                       throws java.lang.Exception

Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.

Parameters:

kvconfig - a KVStoreConfig object

szGraphName - name of the property graph to be created

username - name of the user

password - password of the user

trustStoreFile - the name and path to a client side Java truststore file certificates)

Returns:

an OraclePropertyGraph object

Throws:

java.lang.Exception

getInstance

public static OraclePropertyGraph getInstance(oracle.kv.KVStore kvStore,
                                              oracle.kv.KVStoreConfig kvConfig,
                                              java.lang.String graphName)
                                       throws java.lang.Exception

Throws:

java.lang.Exception

getInstance

public static OraclePropertyGraph getInstance(PgNosqlGraphConfig config)
                                       throws java.lang.Exception

Returns an instance of OraclePropertyGraph using a PGX PgNosqlGraphConfig object.

Parameters:

config - a PgNosqlGraphConfig object

Returns:

an OraclePropertyGraph object

Throws:

java.lang.Exception

getInstance

public static OraclePropertyGraph getInstance(java.lang.String storeName,
                                              java.lang.String host,
                                              int port,
                                              java.lang.String szGraphName)
                                       throws java.lang.Exception

Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.

Parameters:

storeName - kvstore name

host - host machine name where Oracle NoSQL database installed

port - port number

szGraphName - name of the property graph to be created

Returns:

an OraclePropertyGraph object and graph name provided.

Throws:

java.lang.Exception

getInvalidEdgeIDSet

public java.util.Set<java.lang.Long> getInvalidEdgeIDSet(int dop,
                                                         ProgressListener pl)

Gets a set of invalid edges that are stored in the property graph. An invalid edge is an edge whose IN or OUT vertex does not exist in the property graph

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the edges and the vertices tables.

pl - a ProgressListener object.

getKVStoreConfig

public oracle.kv.KVStoreConfig getKVStoreConfig()

Get the KVStoreConfig object associated with the backend database

Returns:

a KVStoreConfig object

getKVStoreConfig

public static oracle.kv.KVStoreConfig getKVStoreConfig(PgNosqlGraphConfig config)

Gets an KVStoreConfig from a PGX PgNosqlGraphConfig object

Parameters:

config - the PgNosqlGraphConfig object

Returns:

the KVStoreConfig object

getLoginCredentials

public oracle.kv.LoginCredentials getLoginCredentials()

getMaxEdgeID

public long getMaxEdgeID(int dop,
                         ProgressListener pl)

Get the maximum edge ID using parallel scan and the specified DOP.

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the vertices.

pl - a ProgressListener object.

Returns:

maximum edge ID in the graph

getMaxVertexID

public long getMaxVertexID(int dop,
                           ProgressListener pl)

Get maximum vertex ID using parallel scans and the specified DOP.

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the vertices.

pl - a ProgressListener object.

Returns:

maximum vertex ID in the graph

getMinEdgeID

public long getMinEdgeID(int dop,
                         ProgressListener pl)

Get the minimum edge ID using parallel scan with dop threads

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the vertices.

pl - a ProgressListener object.

Returns:

minimum edge ID in the graph

getMinVertexID

public long getMinVertexID(int dop,
                           ProgressListener pl)

Get minimum vertex ID using parallel scans and the specified DOP.

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the vertices.

pl - a ProgressListener object.

Returns:

minimum vertex ID in the graph

getOperationQueueSize

public long getOperationQueueSize()

Get the size of the operation queue

Overrides:

getOperationQueueSize in class OraclePropertyGraphBase

getOracleIndexManager

public OracleIndexManager getOracleIndexManager()

Gets the Oracle PropertyGraphIndex Manager associated to this property graph instance.

Specified by:

getOracleIndexManager in interface OracleIndexableGraph

Specified by:

getOracleIndexManager in class OraclePropertyGraphBase

Returns:

a OracleIndexManager object.

getTableIteratorOptions

public oracle.kv.table.TableIteratorOptions getTableIteratorOptions()

Gets the TableIteratorOptions object associated to this property graph

getVertex

public OracleVertex getVertex(java.lang.Object id)

Return the vertex referenced by the object identifier.

Specified by:

getVertex in class OraclePropertyGraphBase

Parameters:

id - the object identifier of the referenced vertex

Returns:

an Vertex object

getVertexIDSet

public java.util.Set<java.lang.Long> getVertexIDSet(int dop,
                                                    ProgressListener pl)

Gets a set of Vertex IDs that are stored in the property graph

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the vertices table.

pl - a ProgressListener object.

getVertexInstance

public OracleVertexBase getVertexInstance(java.lang.Long vid,
                                          boolean bCreateIfAbsentFromCache,
                                          boolean bSkipStoreToCache)

Returns an instance of OracleVertexBase. If there is no match in the cache and bCreateIfAbsentFromCache is false, then a NULL value will be returned. If the skipStoreToCache is true, then the vertex will not be stored into the cache.

Specified by:

getVertexInstance in class OraclePropertyGraphBase

Parameters:

vid - the id of the vertex

bCreateIfAbsentFromCache - if false, returns a NULL value if there is no match in the cache.

bSkipStoreToCache - if true, the vertex instance will not be stored into the cache.

Returns:

a OracleVertexBase object.

getVertexPropertyNames

public int getVertexPropertyNames(int dop,
                                  int timeout,
                                  java.util.Map<java.lang.String,java.lang.Class> propertyNames,
                                  ProgressListener pl)

Gets the property names of all vertices using parallel scans and the specified DOP.

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the vertices

timeout - time out in the unit of seconds

propertyNames - a map of to be returned

pl - a ProgressListener object.

getVertexPropertyNames

public int getVertexPropertyNames(int dop,
                                  int timeout,
                                  java.util.Set<java.lang.String> propertyNames,
                                  ProgressListener pl)

Gets the property names of all vertices using parallel scans and the specified DOP.

Parameters:

dop - a positive integer defining the number of threads to use when parallel scanning the vertices

timeout - time out in the unit of seconds

propertyNames - a set of property names to be returned

pl - a ProgressListener object.

getVertexTableSplits

public int getVertexTableSplits()

Get the number of Vertex table splits used for parallel scans in the vertex table.

Returns:

the number of splits in the vertex table

Throws:

java.io.IOException

getVertexTabName

public java.lang.String getVertexTabName()

Get the name of the Oracle NoSQL Database table used to store vertices in this property graph.

Returns:

the vertex table name.

removeEdge

public void removeEdge(org.apache.tinkerpop.gremlin.structure.Edge edge)

Remove the provided edge from the graph

Specified by:

removeEdge in class OraclePropertyGraphBase

Parameters:

edge - an Edge object to be removed

removeVertex

public void removeVertex(org.apache.tinkerpop.gremlin.structure.Vertex vertex)

Remove the provided vertex from the graph

Specified by:

removeVertex in class OraclePropertyGraphBase

Parameters:

vertex - a Vertex object to be removed

setClearTableDOP

public void setClearTableDOP(int dop)

Sets the number of workers to be used when removing all rows from a table

Parameters:

dop - degree of parallelism

setClearTablePKBufferSize

public void setClearTablePKBufferSize(int size)

Set the size of the primary key buffer used when removing all rows from a table

Parameters:

size - buffer size

setClearTableThreadsPerWorker

public void setClearTableThreadsPerWorker(int threads)

Sets the number of threads per clear table worker to be used when removing all rows from a table

Parameters:

threads - number of threads per clear table worker

setCustomizedParallelScanDOP

public void setCustomizedParallelScanDOP(int iDOP)

Set the dop used for parallel scan

setTableIteratorOptions

public void setTableIteratorOptions(oracle.kv.table.TableIteratorOptions tio)

Sets the TableIteratorOptions object associated to this property graph

updateGraph

public <T extends org.apache.tinkerpop.gremlin.structure.Element> void updateGraph(OpCallback<T> oc,
                                                                                   boolean skipStoreToCache,
                                                                                   int dop,
                                                                                   ProgressListener pl,
                                                                                   OpCallback.UpdateType updateType)

Updates a graph based on the specified OpCallback.

Parameters:

oc - a OpCallback 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.

verticesByProperty

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesByProperty(java.lang.String key,
                                                                                            java.lang.Object value,
                                                                                            java.lang.Class dtClass,
                                                                                            boolean acceptWildcard,
                                                                                            boolean preferredLuceneQuery)

Return an iterable to all matching vertices that have a particular key/value property. When an automatic text index on the given key is absent, a full table scan will be carried out to find matching vertices.

Specified by:

verticesByProperty in class OraclePropertyGraphBase

Parameters:

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 object

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.

verticesByPropertyKey

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesByPropertyKey(java.lang.String[] keys,
                                                                                               VertexFilterCallback vfc,
                                                                                               OraclePropertyGraphBase.OptimizationFlag optFlag)

Return an Iterable to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback. The information read back from the vertices will be complete or partial based on the optimization flag specified.

Specified by:

verticesByPropertyKey in class OraclePropertyGraphBase

Parameters:

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.

optFlag - 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.

verticesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                               boolean bSkipStoreToCache,
                                                                                               int startSplitID)

Gets an array of 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].

Parameters:

kvcArray - an array of KVStoreConfig objects for Oracle NoSQL Database

bSkipStoreToCache - if true, the vertices instances will not be stored into the cache.

startSplitID - the ID of the starting split.

Returns:

an array of Iterable objects.

verticesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                               boolean bSkipStoreToCache,
                                                                                               int iTotalSplits,
                                                                                               int iStartSplitID,
                                                                                               boolean bOptimizedSplits,
                                                                                               java.lang.String[] keys,
                                                                                               VertexFilterCallback vfc,
                                                                                               OraclePropertyGraphBase.OptimizationFlag optFlag)

Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback. The information read back from the vertices will be complete or partial based on the optimization flag specified. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. 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 [iStartSplitID, iStartSplit - 1 + size of connections array].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the vertices instances will not be stored into the cache.

iTotalSplits - the total number of splits

iStartSplitID - the ID of the starting split.

bOptimizedSplits - the flag showing if using optimized splits

keys - an array of property key names. It can be NULL which implies all vertices in the graph will be returned.

vfc - a VertexFilterCallback object specifying the conditions to keep an vertex in the Iterable.

optFlag - 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.

Returns:

an Iterable array object.

verticesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                               boolean bSkipStoreToCache,
                                                                                               int iTotalSplits,
                                                                                               int startSplitID,
                                                                                               java.lang.String[] keys,
                                                                                               VertexFilterCallback vfc,
                                                                                               OraclePropertyGraphBase.OptimizationFlag optFlag)

Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback. The information read back from the vertices will be complete or partial based on the optimization flag specified. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the vertices instances will not be stored into the cache.

iTotalSplits - the total number of splits

startSplitID - the ID of the starting split.

keys - an array of property key names. It can be NULL which implies all vertices in the graph will be returned.

vfc - a VertexFilterCallback object specifying the conditions to keep an vertex in the Iterable.

optFlag - 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.

Returns:

an Iterable array object.

verticesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                               boolean bSkipStoreToCache,
                                                                                               int startSplitID,
                                                                                               java.lang.String key)

Gets an array of Iterable objects that hold all the vertices in the graph that have a particular key. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. The total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

bSkipStoreToCache - if true, the vertices instances will not be stored into the cache.

startSplitID - the ID of the starting split.

key - name of the property. It can be NULL which implies all vertices in the graph will be returned.

Returns:

an Iterable array object.

verticesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                               boolean bSkipStoreToCache,
                                                                                               int startSplitID,
                                                                                               java.lang.String[] keys)

Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. The total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

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 key names. It can be NULL which implies all vertices in the graph will be returned.

Returns:

an Iterable array object.

verticesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                               boolean bSkipStoreToCache,
                                                                                               int startSplitID,
                                                                                               java.lang.String[] keys,
                                                                                               VertexFilterCallback vfc)

Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys and satisfy the specified 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 total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

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 key names. It can be NULL which implies all vertices in the graph will be returned.

vfc - a VertexFilterCallback object specifying the conditions to keep an vertex in the Iterable.

Returns:

an Iterable array object.

verticesPartitioned

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray,
                                                                                               boolean bSkipStoreToCache,
                                                                                               int startSplitID,
                                                                                               java.lang.String[] keys,
                                                                                               VertexFilterCallback vfc,
                                                                                               OraclePropertyGraphBase.OptimizationFlag optFlag)

Gets an array of Iterable objects that hold all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback. The information read back from the vertices will be complete or partial based on the optimization flag specified. Each element in the Iterable array uses a separate connection provided to fetch a subset of the results from the corresponding split. The total splits are determined by the # of connections in the array. 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].

Parameters:

kvcArray - an array of KVStoreConfig to initialize DOP connections to the Oracle NoSQL database. DOP is determined by kvcArray.length.

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 key names. It can be NULL which implies all vertices in the graph will be returned.

vfc - a VertexFilterCallback object specifying the conditions to keep an vertex in the Iterable.

optFlag - 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.

Returns:

an Iterable array object.

verticesWithCustomizedParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesWithCustomizedParallelTableScan(java.lang.String[] keys)

Return an Iterable to all the vertices in the graph that have any of the specified keys.

Parameters:

keys - an array of property key names. It can be NULL which implies all vertices in the graph will be returned.

verticesWithCustomizedParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex>[] verticesWithCustomizedParallelTableScan(java.lang.String[] keys,
                                                                                                                   VertexFilterCallback vfc,
                                                                                                                   OraclePropertyGraphBase.OptimizationFlag optFlag)

Return an Iterable to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback. The information read back from the vertices will be complete or partial based on the optimization flag specified.

Parameters:

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.

optFlag - 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.

verticesWithDefaultParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesWithDefaultParallelTableScan(java.lang.String[] keys)

Return an Iterable to all the vertices in the graph that have any of the specified keys.

Parameters:

keys - an array of property key names. It can be NULL which implies all vertices in the graph will be returned.

verticesWithDefaultParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesWithDefaultParallelTableScan(java.lang.String[] keys,
                                                                                                              VertexFilterCallback vfc)

Return an Iterable to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.

Parameters:

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.

verticesWithDefaultParallelTableScan

public java.util.Iterator<org.apache.tinkerpop.gremlin.structure.Vertex> verticesWithDefaultParallelTableScan(java.lang.String[] keys,
                                                                                                              VertexFilterCallback vfc,
                                                                                                              OraclePropertyGraphBase.OptimizationFlag optFlag)

Return an Iterable to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback. The information read back from the vertices will be complete or partial based on the optimization flag specified.

Parameters:

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.

optFlag - 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.