public class OraclePropertyGraph extends OraclePropertyGraphBase
OraclePropertyGraphBase.OptimizationFlag
TransactionalGraph.Conclusion
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_LONG, TYPE_DT_SERI, TYPE_DT_SHORT, TYPE_DT_STRING
ERR_ARG_CANNOT_BE_NULL, ERR_CODE_NOT_IN_LIST, ERR_DOP_CONSTRAINT, ERR_E_DS_MUSTBE_FILE_OR_IS, ERR_E_MAX_LINE_CONSTRAINT, ERR_EDGE_DIR_NOT_BOTH, 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_IN_DS_EDGE_CANTBE_NULL, ERR_IN_DS_VERT_CANTBE_NULL, ERR_IN_E_FLAT_DOESNT_EXIST, ERR_IN_V_FLAT_DOESNT_EXIST, 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_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_PG_ALREADY_EXISTS, ERR_PG_NOT_EMPTY, ERR_SIZE_MUST_BE_POS, ERR_TIMEOUT_TAB_CREATION, ERR_TYPE_ID_NOT_RECO, ERR_UNSUPPORTED_VAL_TYP, ERR_USER_REQ_OP_CANCEL, 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 . |
Edge |
addEdge(Object id, Vertex outVertex, Vertex inVertex, String label)
This method adds an edge to the graph instance.
|
Vertex |
addVertex(Object id)
This method adds an vertex to the graph instance.
|
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.
|
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
|
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(Object id)
Return the edge referenced by the object identifier.
|
OracleEdgeBase |
getEdgeInstance(Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
Returns an instance of OracleEdgeBase.
|
OracleEdgeBase |
getEdgeInstance(OracleVertexBase outVertex, OracleVertexBase inVertex, String edgeLabel, Long eid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
Returns an instance of OracleEdgeBase.
|
int |
getEdgePropertyNames(int dop, int timeout, Set<String> propertyNames, ProgressListener pl)
Gets the property names of all edges using parallel scans and the specified DOP.
|
Iterable<Edge> |
getEdges(String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Return an
Iterable to all the edges in the graph that have any of the specified keys and satisfy the specified edge filter callback. |
Iterable<Edge> |
getEdges(String key, Object value, Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery)
Return an iterable to all matching edges that have a particular key/value property.
|
Iterable<Edge>[] |
getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID)
Gets an array of
Iterable objects that hold all the edges in the graph. |
Iterable<Edge>[] |
getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int iStartSplitID, boolean bOptimizedSplits, 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. |
Iterable<Edge>[] |
getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int startSplitID, 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. |
Iterable<Edge>[] |
getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, String key)
Gets an array of
Iterable objects that hold all the edges in the graph that have a particular key. |
Iterable<Edge>[] |
getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, String[] keys)
Gets an array of
Iterable objects that hold all the edges in the graph that have any of the specified keys. |
Iterable<Edge>[] |
getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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. |
Iterable<Edge>[] |
getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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. |
Iterable<Edge>[] |
getEdgesWithCustomizedParallelTableScan(String[] keys)
Return an
Iterable to all the edges in the graph that have any of the specified keys. |
Iterable<Edge>[] |
getEdgesWithCustomizedParallelTableScan(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. |
Iterable<Edge> |
getEdgesWithDefaultParallelTableScan(String[] keys)
Return an
Iterable to all the edges in the graph that have any of the specified keys. |
Iterable<Edge> |
getEdgesWithDefaultParallelTableScan(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. |
Iterable<Edge> |
getEdgesWithDefaultParallelTableScan(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.
|
String |
getEdgeTabName()
Get the name of the Oracle NoSQL Database table used to store edges in this property graph.
|
Features |
getFeatures()
Get the particular features of the graph implementation.
|
String |
getGraphName()
This method returns the name of this property graph instance
|
static OraclePropertyGraph |
getInstance(oracle.kv.KVStoreConfig kvconfig, String szGraphName)
Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(oracle.kv.KVStoreConfig kvconfig, 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, String szGraphName, String username, String password)
Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(oracle.kv.KVStoreConfig kvconfig, String szGraphName, String username, String password, Properties secProperties)
Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(oracle.kv.KVStoreConfig kvconfig, String szGraphName, String username, String password, 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(String storeName, String host, int port, String szGraphName)
Returns an instance of OraclePropertyGraph using the Oracle NoSQL Database connection and graph name provided.
|
Set<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(Object id)
Return the vertex referenced by the object identifier.
|
Set<Long> |
getVertexIDSet(int dop, ProgressListener pl)
Gets a set of Vertex IDs that are stored in the property graph
|
OracleVertexBase |
getVertexInstance(Long vid, boolean bCreateIfAbsentFromCache, boolean bSkipStoreToCache)
Returns an instance of OracleVertexBase.
|
int |
getVertexPropertyNames(int dop, int timeout, Set<String> propertyNames, ProgressListener pl)
Gets the property names of all vertices using parallel scans and the specified DOP.
|
int |
getVertexTableSplits()
Get the number of Vertex table splits used for parallel scans in the vertex table.
|
String |
getVertexTabName()
Get the name of the Oracle NoSQL Database table used to store vertices in this property graph.
|
Iterable<Vertex> |
getVertices(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. |
Iterable<Vertex> |
getVertices(String key, Object value, Class dtClass, boolean acceptWildcard, boolean preferredLuceneQuery)
Return an iterable to all matching vertices that have a particular key/value property.
|
Iterable<Vertex>[] |
getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID)
Gets an array of
Iterable objects that hold all the vertices in the graph. |
Iterable<Vertex>[] |
getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int iStartSplitID, boolean bOptimizedSplits, 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. |
Iterable<Vertex>[] |
getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int startSplitID, 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. |
Iterable<Vertex>[] |
getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, String key)
Gets an array of
Iterable objects that hold all the vertices in the graph that have a particular key. |
Iterable<Vertex>[] |
getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, String[] keys)
Gets an array of
Iterable objects that hold all the vertices in the graph that have any of the specified keys. |
Iterable<Vertex>[] |
getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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. |
Iterable<Vertex>[] |
getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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. |
Iterable<Vertex>[] |
getVerticesWithCustomizedParallelTableScan(String[] keys)
Return an
Iterable to all the vertices in the graph that have any of the specified keys. |
Iterable<Vertex>[] |
getVerticesWithCustomizedParallelTableScan(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. |
Iterable<Vertex> |
getVerticesWithDefaultParallelTableScan(String[] keys)
Return an
Iterable to all the vertices in the graph that have any of the specified keys. |
Iterable<Vertex> |
getVerticesWithDefaultParallelTableScan(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. |
Iterable<Vertex> |
getVerticesWithDefaultParallelTableScan(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. |
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(Edge edge)
Remove the provided edge from the graph
|
void |
removeVertex(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.
|
String |
toString()
Returns a very succinct String representation of this Graph instance
|
addAttributeToAllEdges, addAttributeToAllEdges, addAttributeToAllVertices, addAttributeToAllVertices, commitIndices, countEdges, countEdges, countVertices, countVertices, createIndex, createKeyIndex, createKeyIndex, createKeyIndex, dropAllAutoIndices, dropAllIndices, dropAllManualIndices, dropIndex, dropKeyIndex, dropKeyIndex, dropKeyIndex, getAutoIndex, getBatchSize, getConfig, getDefaultEdgeOptFlag, getDefaultIndexParameters, getDefaultVertexOptFlag, getEdgeFilterCallback, getEdgePropertyNames, getEdges, getEdges, getEdges, getEdges, getEdges, getEdges, getEdges, getEdges, getIndex, getIndexedKeys, getIndexParameters, getIndices, getInvalidEdgeIDSet, getInvalidEdgeIDSet, getMaxEdgeID, getMaxEdgeID, getMaxVertexID, getMaxVertexID, getMinEdgeID, getMinEdgeID, getMinVertexID, getMinVertexID, getProgressListener, getQueueSize, getShortestPath, getShortestPath, getSimpleDateFormat, getStringForObj, getVertexFilterCallback, getVertexIDSet, getVertexIDSet, getVertexPropertyNames, getVertexPropertyNames, getVertexPropertyNames, getVertices, getVertices, getVertices, getVertices, getVertices, getVertices, getVertices, getVertices, isEdgeAutoIndexEnabled, isEmpty, isVertexAutoIndexEnabled, query, refreshAutoIndices, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllVertices, removeAttributeFromAllVertices, rollback, serializableToStr, setBatchSize, setDefaultEdgeOptFlag, setDefaultIndexParameters, setDefaultVertexOptFlag, setEdgeFilterCallback, setProgressListener, setQueueSize, setVertexFilterCallback, startTransaction, stopTransaction, strToSerializable, sum
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 Edge addEdge(Object id, Vertex outVertex, Vertex inVertex, String label)
addEdge
in interface 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(Object id)
addVertex
in interface Graph
addVertex
in class OraclePropertyGraphBase
id
- the id of the vertexOracleVertex
object.public void clearCache()
public void clearRepository() throws Exception
clearRepository
in class OraclePropertyGraphBase
Exception
public void closeKVStore()
public void commit()
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 Exception
Exception
public void createIndexTable() throws Exception
Exception
public int getClearTableDOP()
public int getClearTablePKBufferSize()
public int getClearTableThreadsPerWorker()
public int getCustomizedParallelScanDOP()
public OracleEdge getEdge(Object id)
getEdge
in interface Graph
getEdge
in class OraclePropertyGraphBase
id
- the object identifier of the referenced edgeOracleEdge
objectpublic OracleEdgeBase getEdgeInstance(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, String edgeLabel, 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, Set<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 Iterable<Edge> getEdges(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 Iterable<Edge> getEdges(String key, Object value, 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 Iterable<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 Iterable<Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int iStartSplitID, boolean bOptimizedSplits, 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 Iterable<Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int startSplitID, 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 Iterable<Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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 Iterable<Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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 Iterable<Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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 Iterable<Edge>[] getEdgesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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 Iterable<Edge>[] getEdgesWithCustomizedParallelTableScan(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 Iterable<Edge>[] getEdgesWithCustomizedParallelTableScan(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 Iterable<Edge> getEdgesWithDefaultParallelTableScan(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 Iterable<Edge> getEdgesWithDefaultParallelTableScan(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 Iterable<Edge> getEdgesWithDefaultParallelTableScan(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()
IOException
public String getEdgeTabName()
public Features getFeatures()
public String getGraphName()
getGraphName
in class OraclePropertyGraphBase
public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig, String szGraphName) throws Exception
kvconfig
- a KVStoreConfig
objectszGraphName
- name of the property graph to be createdOraclePropertyGraph
objectException
public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig, String szGraphName, oracle.kv.LoginCredentials lc) throws Exception
kvconfig
- a KVStoreConfig
objectszGraphName
- name of the property graph to be createdlc
- a LoginCredentials object that can be used to authenticate a userOraclePropertyGraph
objectException
public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig, String szGraphName, String username, String password) throws Exception
kvconfig
- a KVStoreConfig
objectszGraphName
- name of the property graph to be createdusername
- name of the userpassword
- password of the userOraclePropertyGraph
objectException
public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig, String szGraphName, String username, String password, Properties secProperties) throws 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
objectException
public static OraclePropertyGraph getInstance(oracle.kv.KVStoreConfig kvconfig, String szGraphName, String username, String password, String trustStoreFile) throws 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
objectException
public static OraclePropertyGraph getInstance(oracle.pgx.config.PgNosqlGraphConfig config) throws Exception
config
- a PgNosqlGraphConfig
objectOraclePropertyGraph
objectException
public static OraclePropertyGraph getInstance(String storeName, String host, int port, String szGraphName) throws 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.Exception
public Set<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 vertices.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(Object id)
getVertex
in interface Graph
getVertex
in class OraclePropertyGraphBase
id
- the object identifier of the referenced vertexVertex
objectpublic Set<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.pl
- a ProgressListener object.public OracleVertexBase getVertexInstance(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, Set<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()
IOException
public String getVertexTabName()
public Iterable<Vertex> getVertices(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 Iterable<Vertex> getVertices(String key, Object value, 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 Iterable<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 Iterable<Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int iStartSplitID, boolean bOptimizedSplits, 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 Iterable<Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int iTotalSplits, int startSplitID, 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 Iterable<Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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 Iterable<Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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 Iterable<Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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 Iterable<Vertex>[] getVerticesPartitioned(oracle.kv.KVStoreConfig[] kvcArray, boolean bSkipStoreToCache, int startSplitID, 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 Iterable<Vertex>[] getVerticesWithCustomizedParallelTableScan(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 Iterable<Vertex>[] getVerticesWithCustomizedParallelTableScan(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 Iterable<Vertex> getVerticesWithDefaultParallelTableScan(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 Iterable<Vertex> getVerticesWithDefaultParallelTableScan(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 Iterable<Vertex> getVerticesWithDefaultParallelTableScan(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 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(Edge edge)
removeEdge
in interface Graph
removeEdge
in class OraclePropertyGraphBase
edge
- an Edge
object to be removedpublic void removeVertex(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()
Copyright © 2016 Oracle and/or its afflilates. All Rights Reserved.