public class OraclePropertyGraph extends OraclePropertyGraphBase
OraclePropertyGraphBase.OptimizationFlag
Graph.Exceptions, Graph.Features, Graph.Hidden, Graph.OptIn, Graph.OptIns, Graph.OptOut, Graph.OptOuts, Graph.Variables
OraclePropertyGraphConstants.QueueAction
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
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
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
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
Modifier and Type | Method and Description |
---|---|
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, boolean skipStoreToCache, int dop, ProgressListener pl)
Adds an attribute to all vertices based on the specified
VertexOpCallback . |
com.tinkerpop.blueprints.Edge |
addEdge(java.lang.Object id, com.tinkerpop.blueprints.Vertex outVertex, com.tinkerpop.blueprints.Vertex inVertex, java.lang.String label)
This method adds an edge to the graph instance.
|
Edge |
addEdge(java.lang.Object id, Vertex v, Vertex anotherv, java.lang.String label) |
Vertex |
addVertex(java.lang.Object... keyValues)
Add a Vertex to the graph given an optional series of key/value pairs.
|
com.tinkerpop.blueprints.Vertex |
addVertex(java.lang.Object id)
This method adds an vertex to the graph instance.
|
Vertex |
addVertex(java.lang.String label)
Add a Vertex to the graph with provided vertex label.
|
void |
clearCache()
Clear the vertex cache and edge cache
|
void |
clearRepository()
This method removes all vertices and edges from this property graph instance.
|
void |
closeKVStore()
This method closes the underlying KVStore instance
|
void |
commit()
Commit changes done to this property graph instace.
|
GraphComputer |
compute()
Generate a GraphComputer using the default engine of the underlying graph system.
|
<C extends GraphComputer> |
compute(java.lang.Class<C> graphComputerClass)
Declare the GraphComputer to use for OLAP operations on the graph.
|
org.apache.commons.configuration.Configuration |
configuration()
Get the org.apache.commons.configuration.Configuration associated with the construction of this graph.
|
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<Edge> |
edges(java.lang.Object... edgeIds)
Get the Edge objects in this graph with the provided edge ids or Edge objects.
|
Graph.Features |
features()
Gets the particular features of the graph implementation for Tinkerpop 2.3
|
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
|
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.Set<java.lang.String> propertyNames, ProgressListener pl)
Gets the property names of all edges using parallel scans and the specified DOP.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdges(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.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdges(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.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID)
Gets an array of
Iterable objects that hold all the edges in the graph. |
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesWithCustomizedParallelTableScan(java.lang.String[] keys)
Return an
Iterable to all the edges in the graph that have any of the specified keys. |
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesWithCustomizedParallelTableScan(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.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdgesWithDefaultParallelTableScan(java.lang.String[] keys)
Return an
Iterable to all the edges in the graph that have any of the specified keys. |
java.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdgesWithDefaultParallelTableScan(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.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdgesWithDefaultParallelTableScan(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. |
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.
|
java.lang.Iterable<java.util.Map.Entry<java.lang.Object,java.lang.Object>> |
getElementsProperties(java.lang.Object[] ids, java.lang.String propertyName, int dop, java.lang.Class<? extends com.tinkerpop.blueprints.Element> elementClass) |
com.tinkerpop.blueprints.Features |
getFeatures()
Gets the particular features of the graph implementation for Tinkerpop 3
|
java.lang.String |
getGraphName()
This method returns the name of this property graph instance
|
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.pgx.config.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(oracle.pgx.config.PgNosqlGraphConfig config)
Gets an KVStoreConfig from a PGX
PgNosqlGraphConfig object |
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.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.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex> |
getVertices(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.lang.Iterable<com.tinkerpop.blueprints.Vertex> |
getVertices(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.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID)
Gets an array of
Iterable objects that hold all the vertices in the graph. |
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(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.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesWithCustomizedParallelTableScan(java.lang.String[] keys)
Return an
Iterable to all the vertices in the graph that have any of the specified keys. |
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesWithCustomizedParallelTableScan(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.lang.Iterable<com.tinkerpop.blueprints.Vertex> |
getVerticesWithDefaultParallelTableScan(java.lang.String[] keys)
Return an
Iterable to all the vertices in the graph that have any of the specified keys. |
java.lang.Iterable<com.tinkerpop.blueprints.Vertex> |
getVerticesWithDefaultParallelTableScan(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.lang.Iterable<com.tinkerpop.blueprints.Vertex> |
getVerticesWithDefaultParallelTableScan(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. |
<I extends Io> |
io(Io.Builder<I> builder)
Construct a particular Io implementation for reading and writing the Graph and other data.
|
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, boolean skipStoreToCache, int dop, ProgressListener pl)
Removes an attribute from all vertices based on the specified
VertexOpCallback . |
void |
removeEdge(com.tinkerpop.blueprints.Edge edge)
Remove the provided edge from the graph
|
void |
removeVertex(com.tinkerpop.blueprints.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
|
void |
shutdown()
A shutdown function is required to properly close the graph.
|
java.lang.String |
toString()
Returns a very succinct String representation of this Graph instance
|
GraphTraversalSource |
traversal()
Generate a reusable GraphTraversalSource instance.
|
<C extends TraversalSource> |
traversal(java.lang.Class<C> traversalSourceClass)
Generate a TraversalSource using the specified TraversalSource class.
|
Transaction |
tx()
Configure and control the transactions for those graphs that support this feature.
|
Graph.Variables |
variables()
A collection of global Graph.Variables associated with the graph.
|
java.util.Iterator<Vertex> |
vertices(java.lang.Object... vertexIds)
Get the Vertex objects in this graph with the provided vertex ids or Vertex objects themselves.
|
addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllVertices, addAttributeToAllVertices, close, commitIndices, countEdges, countEdges, countVertices, countVertices, createIndex, createKeyIndex, createKeyIndex, createKeyIndex, dropAllAutoIndices, dropAllIndices, dropAllManualIndices, dropIndex, dropKeyIndex, dropKeyIndex, dropKeyIndex, getAdjacentEdgesFromVertices, getAdjacentEdgesFromVertices, getAutoIndex, getBatchSize, getConfig, getDatatypeClassFromValueObjForTextIndex, getDefaultEdgeOptFlag, getDefaultIndexParameters, getDefaultVertexOptFlag, getEdgeFilterCallback, getEdgePropertyNames, getEdges, getEdges, getEdges, getEdges, getEdges, getEdges, getEdges, getEdges, getEdgesByIds, getEdgesByIds, getEdgesUsingTextSearch, getElementsProperties, getIndex, getIndexedKeys, getIndexParameters, getIndices, getInvalidEdgeIDSet, getInvalidEdgeIDSet, getJustEdgeIdOptFlag, getJustVertexIdOptFlag, getMaxEdgeID, getMaxEdgeID, getMaxVertexID, getMaxVertexID, getMinEdgeID, getMinEdgeID, getMinVertexID, getMinVertexID, getProgressListener, getQueueSize, getShortestPath, getShortestPath, getSimpleDateFormat, getStringForObj, getTextIndexDirectoryPrefix, getVertexFilterCallback, getVertexIDSet, getVertexIDSet, getVertexPropertyNames, getVertices, getVertices, getVertices, getVertices, getVertices, getVertices, getVertices, getVertices, getVerticesByIds, getVerticesByIds, getVerticesUsingTextSearch, isDisposed, isEdgeAutoIndexEnabled, isEmpty, isShutdown, isTransientPropertyGraphInstance, isVertexAutoIndexEnabled, query, refreshAutoIndices, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllVertices, removeAttributeFromAllVertices, rollback, serializableToStr, setBatchSize, setDefaultEdgeOptFlag, setDefaultIndexParameters, setDefaultVertexOptFlag, setEdgeFilterCallback, setProgressListener, setQueueSize, setSolrJavaBinFormat, setTransientPropertyGraphInstance, setVertexFilterCallback, startTransaction, stopTransaction, strToSerializable, sum, useSolrJavaBinFormat
public void addAttributeToAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop, ProgressListener pl)
EdgeOpCallback
.addAttributeToAllEdges
in class OraclePropertyGraphBase
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, boolean skipStoreToCache, int dop, ProgressListener pl)
VertexOpCallback
.addAttributeToAllVertices
in class OraclePropertyGraphBase
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 com.tinkerpop.blueprints.Edge addEdge(java.lang.Object id, com.tinkerpop.blueprints.Vertex outVertex, com.tinkerpop.blueprints.Vertex inVertex, java.lang.String label)
addEdge
in interface com.tinkerpop.blueprints.Graph
addEdge
in class OraclePropertyGraphBase
id
- the id of the edgeoutVertex
- has to be of type OracleVertexinVertex
- has to be of type OracleVertexlabel
- edge labelOracleEdge
object.public Vertex addVertex(java.lang.Object... keyValues)
keyValues
- The key/value pairs to turn into vertex propertiespublic com.tinkerpop.blueprints.Vertex addVertex(java.lang.Object id)
addVertex
in interface com.tinkerpop.blueprints.Graph
addVertex
in class OraclePropertyGraphBase
id
- the id of the vertexOracleVertex
object.public Vertex addVertex(java.lang.String label)
label
- the label of the vertexpublic void clearCache()
clearCache
in class OraclePropertyGraphBase
public void clearRepository() throws java.lang.Exception
clearRepository
in class OraclePropertyGraphBase
java.lang.Exception
public void closeKVStore()
public void commit()
public GraphComputer compute() throws java.lang.IllegalArgumentException
java.lang.UnsupportedOperationException
java.lang.IllegalArgumentException
public <C extends GraphComputer> C compute(java.lang.Class<C> graphComputerClass) throws java.lang.IllegalArgumentException
graphComputerClass
- the graph computer class to usejava.lang.IllegalArgumentException
- if the provided GraphComputer class is not supportedjava.lang.UnsupportedOperationException
public org.apache.commons.configuration.Configuration configuration()
java.lang.UnsupportedOperationException
public long countEdges(int dop, ProgressListener pl)
countEdges
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the edges.pl
- a ProgressListener object.public long countVertices(int dop, ProgressListener pl)
countVertices
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pl
- a ProgressListener object.public void createGraphTables() throws java.lang.Exception
java.lang.Exception
public void createIndexTable() throws java.lang.Exception
java.lang.Exception
public void dispose()
public java.util.Iterator<Edge> edges(java.lang.Object... edgeIds)
edgeIds
- the ids of the edges to getpublic Graph.Features features()
public int getClearTableDOP()
public int getClearTablePKBufferSize()
public int getClearTableThreadsPerWorker()
public int getCustomizedParallelScanDOP()
public OracleEdge getEdge(java.lang.Object id)
getEdge
in interface com.tinkerpop.blueprints.Graph
getEdge
in class OraclePropertyGraphBase
id
- the object identifier of the referenced edgeOracleEdge
objectpublic OracleEdgeBase getEdgeInstance(java.lang.Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getEdgeInstance
in class OraclePropertyGraphBase
eid
- the id of the edgebCreateIfAbsentFromCache
- 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.public OracleEdgeBase getEdgeInstance(OracleVertexBase outVertex, OracleVertexBase inVertex, java.lang.String edgeLabel, java.lang.Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getEdgeInstance
in class OraclePropertyGraphBase
eid
- the id of the edgeoutVertex
- the outgoing Vertex of the edgeinVertex
- the incoming Vertex of the edgeedgeLabel
- 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.public int getEdgePropertyNames(int dop, int timeout, java.util.Set<java.lang.String> propertyNames, ProgressListener pl)
getEdgePropertyNames
in class OraclePropertyGraphBase
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 java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdges(java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
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.getEdges
in class OraclePropertyGraphBase
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 java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdges(java.lang.String key, java.lang.Object value, java.lang.Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery)
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 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.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, 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 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].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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int iStartSplitID, boolean bOptimizedSplits, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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].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 splitsiStartSplitID
- the ID of the starting split.bOptimizedSplits
- the flag showing if using optimized splitskeys
- 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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int startSplitID, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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].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 splitsstartSplitID
- 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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String key)
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].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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys)
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].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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys, EdgeFilterCallback efc)
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].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
.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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].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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesWithCustomizedParallelTableScan(java.lang.String[] keys)
Iterable
to all the edges in the graph that have any of the specified keys.keys
- an array of property key names. It can be NULL which implies all edges in the graph will be returned.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesWithCustomizedParallelTableScan(java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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.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.public java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdgesWithDefaultParallelTableScan(java.lang.String[] keys)
Iterable
to all the edges in the graph that have any of the specified keys.keys
- an array of property key names. It can be NULL which implies all edges in the graph will be returned.public java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdgesWithDefaultParallelTableScan(java.lang.String[] keys, EdgeFilterCallback efc)
Iterable
to all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback.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 java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdgesWithDefaultParallelTableScan(java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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.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.public int getEdgeTableSplits()
java.io.IOException
public java.lang.String getEdgeTabName()
public java.lang.Iterable<java.util.Map.Entry<java.lang.Object,java.lang.Object>> getElementsProperties(java.lang.Object[] ids, java.lang.String propertyName, int dop, java.lang.Class<? extends com.tinkerpop.blueprints.Element> elementClass)
getElementsProperties
in class OraclePropertyGraphBase
public com.tinkerpop.blueprints.Features getFeatures()
public java.lang.String getGraphName()
getGraphName
in class OraclePropertyGraphBase
public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig, java.lang.String szGraphName) throws java.lang.Exception
kvconfig
- a KVStoreConfig
objectszGraphName
- name of the property graph to be createdOraclePropertyGraph
objectjava.lang.Exception
public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig, java.lang.String szGraphName, oracle.kv.LoginCredentials lc) throws java.lang.Exception
kvconfig
- a KVStoreConfig
objectszGraphName
- name of the property graph to be createdlc
- a LoginCredentials object that can be used to authenticate a userOraclePropertyGraph
objectjava.lang.Exception
public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig, java.lang.String szGraphName, java.lang.String username, java.lang.String password) throws java.lang.Exception
kvconfig
- a KVStoreConfig
objectszGraphName
- name of the property graph to be createdusername
- name of the userpassword
- password of the userOraclePropertyGraph
objectjava.lang.Exception
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
kvconfig
- a KVStoreConfig
objectszGraphName
- name of the property graph to be createdusername
- name of the userpassword
- password of the usersecProperties
- a Properties object that defines the KVStoreConfig security settingsOraclePropertyGraph
objectjava.lang.Exception
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
kvconfig
- a KVStoreConfig
objectszGraphName
- name of the property graph to be createdusername
- name of the userpassword
- password of the usertrustStoreFile
- the name and path to a client side Java truststore file certificates)OraclePropertyGraph
objectjava.lang.Exception
public static OraclePropertyGraph getInstance(oracle.pgx.config.PgNosqlGraphConfig config) throws java.lang.Exception
config
- a PgNosqlGraphConfig
objectOraclePropertyGraph
objectjava.lang.Exception
public static OraclePropertyGraph getInstance(java.lang.String storeName, java.lang.String host, int port, java.lang.String szGraphName) throws java.lang.Exception
storeName
- kvstore namehost
- host machine name where Oracle NoSQL database installedport
- port numberszGraphName
- name of the property graph to be createdOraclePropertyGraph
object and graph name provided.java.lang.Exception
public java.util.Set<java.lang.Long> getInvalidEdgeIDSet(int dop, ProgressListener pl)
getInvalidEdgeIDSet
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the edges and the vertices tables.pl
- a ProgressListener object.public oracle.kv.KVStoreConfig getKVStoreConfig()
KVStoreConfig
object associated with the backend databaseKVStoreConfig
objectpublic static oracle.kv.KVStoreConfig getKVStoreConfig(oracle.pgx.config.PgNosqlGraphConfig config)
PgNosqlGraphConfig
objectconfig
- the PgNosqlGraphConfig
objectpublic long getMaxEdgeID(int dop, ProgressListener pl)
getMaxEdgeID
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pl
- a ProgressListener object.public long getMaxVertexID(int dop, ProgressListener pl)
getMaxVertexID
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pl
- a ProgressListener object.public long getMinEdgeID(int dop, ProgressListener pl)
getMinEdgeID
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pl
- a ProgressListener object.public long getMinVertexID(int dop, ProgressListener pl)
getMinVertexID
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pl
- a ProgressListener object.public long getOperationQueueSize()
public OracleIndexManager getOracleIndexManager()
getOracleIndexManager
in class OraclePropertyGraphBase
OracleIndexManager
object.public oracle.kv.table.TableIteratorOptions getTableIteratorOptions()
public OracleVertex getVertex(java.lang.Object id)
getVertex
in interface com.tinkerpop.blueprints.Graph
getVertex
in class OraclePropertyGraphBase
id
- the object identifier of the referenced vertexVertex
objectpublic java.util.Set<java.lang.Long> getVertexIDSet(int dop, ProgressListener pl)
getVertexIDSet
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices table.pl
- a ProgressListener object.public OracleVertexBase getVertexInstance(java.lang.Long vid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
getVertexInstance
in class OraclePropertyGraphBase
vid
- the id of the vertexbCreateIfAbsentFromCache
- 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.public int getVertexPropertyNames(int dop, int timeout, java.util.Set<java.lang.String> propertyNames, ProgressListener pl)
getVertexPropertyNames
in class OraclePropertyGraphBase
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 int getVertexTableSplits()
java.io.IOException
public java.lang.String getVertexTabName()
public java.lang.Iterable<com.tinkerpop.blueprints.Vertex> getVertices(java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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.getVertices
in class OraclePropertyGraphBase
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.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex> getVertices(java.lang.String key, java.lang.Object value, java.lang.Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery)
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.preferredLuceneQuery
- if true, a look up to the automatic index will be executed to find the matches.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, 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].kvcArray
- an array of KVStoreConfig objects for Oracle NoSQL DatabasebSkipStoreToCache
- if true, the vertices instances will not be stored into the cache.startSplitID
- the ID of the starting split.Iterable
objects.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int iStartSplitID, boolean bOptimizedSplits, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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].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 splitsiStartSplitID
- the ID of the starting split.bOptimizedSplits
- the flag showing if using optimized splitskeys
- 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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int startSplitID, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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].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 splitsstartSplitID
- 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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String key)
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].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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys)
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].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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys, VertexFilterCallback vfc)
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].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
.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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].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.Iterable
array object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesWithCustomizedParallelTableScan(java.lang.String[] keys)
Iterable
to all the vertices in the graph that have any of the specified keys.keys
- an array of property key names. It can be NULL which implies all vertices in the graph will be returned.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesWithCustomizedParallelTableScan(java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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.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.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex> getVerticesWithDefaultParallelTableScan(java.lang.String[] keys)
Iterable
to all the vertices in the graph that have any of the specified keys.keys
- an array of property key names. It can be NULL which implies all vertices in the graph will be returned.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex> getVerticesWithDefaultParallelTableScan(java.lang.String[] keys, VertexFilterCallback vfc)
Iterable
to all the vertices in the graph that have any of the specified keys and satisfy the specified vertex filter callback.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 java.lang.Iterable<com.tinkerpop.blueprints.Vertex> getVerticesWithDefaultParallelTableScan(java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag optFlag)
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.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.public <I extends Io> I io(Io.Builder<I> builder)
public void removeAttributeFromAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop, ProgressListener pl)
EdgeOpCallback
.removeAttributeFromAllEdges
in class OraclePropertyGraphBase
eoc
- a 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, boolean skipStoreToCache, int dop, ProgressListener pl)
VertexOpCallback
.removeAttributeFromAllVertices
in class OraclePropertyGraphBase
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(com.tinkerpop.blueprints.Edge edge)
removeEdge
in interface com.tinkerpop.blueprints.Graph
removeEdge
in class OraclePropertyGraphBase
edge
- an Edge
object to be removedpublic void removeVertex(com.tinkerpop.blueprints.Vertex vertex)
vertex
- a Vertex
object to be removedpublic void setClearTableDOP(int dop)
dop
- degree of parallelismpublic void setClearTablePKBufferSize(int size)
size
- buffer sizepublic void setClearTableThreadsPerWorker(int threads)
threads
- number of threads per clear table workerpublic void setCustomizedParallelScanDOP(int iDOP)
public void setTableIteratorOptions(oracle.kv.table.TableIteratorOptions tio)
public void shutdown()
public java.lang.String toString()
toString
in class java.lang.Object
public GraphTraversalSource traversal()
public <C extends TraversalSource> C traversal(java.lang.Class<C> traversalSourceClass)
traversalSourceClass
- the traversal source classpublic Transaction tx()
java.lang.UnsupportedOperationException
public Graph.Variables variables()
java.lang.UnsupportedOperationException
public java.util.Iterator<Vertex> vertices(java.lang.Object... vertexIds)
vertexIds
- the ids of the vertices to getCopyright © 2015 - 2018 Oracle and/or its afflilates. All Rights Reserved.