public class OraclePropertyGraph extends OraclePropertyGraphBase implements OraclePropertyGraphAnalytics, OracleChangeTracker
Modifier and Type | Class and Description |
---|---|
static class |
OraclePropertyGraph.Sort
This enumeration denotes the sorting order for function getTopK
|
OraclePropertyGraphBase.OptimizationFlag
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEFAULT_NUMBER_FORMAT
This constant denotes the default number format used in SQL Statements
|
static java.lang.String |
DEFAULT_TIME_FORMAT
This constant denotes the default datetime format used in SQL Statements
|
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
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)
Adds an edge to the graph instance.
|
com.tinkerpop.blueprints.Vertex |
addVertex(java.lang.Object id)
Adds an vertex to the graph instance.
|
void |
analyze(float estimatePercent, java.lang.String methodOpt)
Collects statistics for this graph.
|
void |
analyze(float estimatePercent, java.lang.String methodOpt, int dop)
Collects statistics for this graph.
|
void |
analyze(int dop)
Collects statistics for this graph.
|
void |
analyzeAuto(int dop)
Collects statistics for this graph.
|
void |
clearCache()
Clears the internal Vertex and Edge cache.
|
void |
clearRepository()
Removes all vertices and edges from this property graph instance.
|
void |
clearUpdateQueue()
Clears the update action queue.
|
void |
collaborativeFiltering(java.lang.String szEdgeTabName, java.lang.String szLabel, java.lang.String szRatingProperty, int iterations, double minError, int features, double learningRate, double decreaseRate, double regularizationParam, int dop, java.lang.StringBuilder sbLeft, java.lang.StringBuilder sbRight, java.lang.StringBuilder sbLeft1, java.lang.StringBuilder sbRight1, java.lang.StringBuilder sbMatrixProduct, java.lang.StringBuilder sbLeftDelta, java.lang.StringBuilder sbRightDelta, java.lang.String szTBS, java.lang.String szOptions)
This method performs collaborative filtering using matrix factorization on the graph.
|
java.lang.Double |
collaborativeFilteringCheckIntermediateError(double regularizationParam, int dop, java.lang.StringBuilder sbMatrixProduct)
This method checks the intermediate error in the collaborative filtering using matrix factorization on the graph.
|
void |
collaborativeFilteringCleanup(java.lang.String szEdgeTabName, java.lang.StringBuilder sbLeft, java.lang.StringBuilder sbRight, java.lang.StringBuilder sbLeft1, java.lang.StringBuilder sbRight1, java.lang.StringBuilder sbMatrixProduct, java.lang.StringBuilder sbLeftDelta, java.lang.StringBuilder sbRightDelta, java.lang.String szOptions)
This method does cleanup work after running graph collaborative filtering.
|
java.lang.Double |
collaborativeFilteringGetRecommendation(java.lang.String szEdgeTabName, int dop, long srcVertex, long dstVertex, java.lang.StringBuilder sbLeft, java.lang.StringBuilder sbRight)
This method gets the recommendation result of the collaborative filtering using matrix factorization on the graph.
|
void |
collaborativeFilteringPrep(java.lang.String szEdgeTabName, java.lang.StringBuilder sbLeft, java.lang.StringBuilder sbRight, java.lang.StringBuilder sbLeft1, java.lang.StringBuilder sbRight1, java.lang.StringBuilder sbMatrixProduct, java.lang.StringBuilder sbLeftDelta, java.lang.StringBuilder sbRightDelta, java.lang.String szOptions)
This method does preparation work before running the collaborative filtering on the graph.
|
void |
commit()
Commit changes done to this property graph instance.
|
void |
commit(boolean bCommitIndices)
Commit changes done to this property graph instance.
|
long |
countEdges(int dop, ProgressListener pll)
Counts all edges using parallel scans and the specified DOP.
|
static long |
countTriangle(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbUndirWorkTab, int iNumSubPtns, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
Returns the number of triangles that exist in this graph.
|
long |
countTriangle(java.lang.StringBuilder sbUndirWorkTab)
Returns the number of triangles that exist in this graph which is treated as undirected.
|
long |
countTriangle(java.lang.StringBuilder sbUndirWorkTab, int iNumSubPtns, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
Returns the number of triangles that exist in this graph.
|
void |
countTriangleCleanup(java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, java.lang.String szOptions)
This method does cleanup work after running triangle calculations.
|
void |
countTrianglePrep(java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, java.lang.String szOptions)
This method does preparation work before running triangle calculations.
|
static long |
countTriangleRenum(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, int iNumSubPtns, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
Returns the number of triangles that exist in this graph (treated as undirected).
|
long |
countTriangleRenum(java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, int iNumSubPtns, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
Returns the number of triangles that exist in this graph (treated as undirected).
|
long |
countVertices(int dop, ProgressListener pll)
Counts all vertices using parallel scan with dop threads
|
void |
createDefaultSpatialIndexOnEdges(int dop)
This API creates a default Spatial index on edges.
|
void |
createDefaultSpatialIndexOnEdges(int dop, boolean bLocal, boolean bUseV2)
This API creates a default Spatial index on edges.
|
void |
createDefaultSpatialIndexOnVertices(int dop)
This API creates a default Spatial index on vertices.
|
void |
createDefaultSpatialIndexOnVertices(int dop, boolean bLocal, boolean bUseV2)
This API creates a default Spatial index on vertices.
|
void |
createStatTable(java.lang.String statTableName)
Creates a stat table using DBMS_STATS package.
|
void |
disable()
Disables the session flash back.
|
java.util.List<java.lang.String> |
disableEdgeTableConstraints()
Disables all the database constraints of the edge table.
|
java.util.List<java.lang.String> |
disableEdgeTableIndices()
Disables all database indices of the edge table.
|
java.util.List<java.lang.String> |
disableVertexTableConstraints()
Disables all the database constraints of the vertex table.
|
java.util.List<java.lang.String> |
disableVertexTableIndices()
Disables all database indices of the vertex table
|
void |
dispose()
Closes the graph without commiting any changes
|
boolean |
doesEdgeExistAt(java.lang.String szEdgeID, java.lang.Long longEndSCN)
Returns TRUE if the edge identified by the given edge ID exist at SCN denoted by the end scn
|
boolean |
doesEdgeExistAt(java.lang.String szEdgeID, java.lang.Long longEndSCN, int iQueryDOP)
Returns TRUE if the edge identified by the given edge ID exist at SCN denoted by the end scn
|
boolean |
doesVertexExistAt(java.lang.String szVertexID, java.lang.Long longEndSCN)
Returns TRUE if the vertex identified by the given vertex ID exist at SCN denoted by the end scn
|
boolean |
doesVertexExistAt(java.lang.String szVertexID, java.lang.Long longEndSCN, int iQueryDOP)
Returns TRUE if the vertex identified by the given vertex ID exist at SCN denoted by the end scn
|
void |
dropDefaultSpatialIndexOnEdges()
This API drops the default Spatial index on edges.
|
void |
dropDefaultSpatialIndexOnVertices()
This API drops the default Spatial index on vertices.
|
void |
enableAtSCN(java.lang.Long longSCN)
Sets the session snapshot to the given SCN value
|
static long |
estimateTriangleRenum(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, int iNumSubPtns, int iChunk, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
This method estimates the number of triangles that exist in this graph (treated as undirected).
|
long |
estimateTriangleRenum(java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, int iNumSubPtns, int iChunk, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
This method estimates the number of triangles that exist in this graph (treated as undirected).
|
void |
expEdgeStat(java.lang.String statTableName, java.lang.String statid)
Exports the edge table statistics into the given stat table.
|
void |
expVertexStat(java.lang.String statTableName, java.lang.String statid)
Exports the vertex table statistics into the given stat table.
|
static void |
findCluster(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbClusters, java.lang.StringBuilder sbUndir, java.lang.StringBuilder sbCluas, java.lang.StringBuilder sbNewas, java.lang.StringBuilder sbDelta, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
This method finds clusters in a given graph (treated as undirected).
|
void |
findCluster(java.lang.StringBuilder sbClusters, java.lang.StringBuilder sbUndir, java.lang.StringBuilder sbCluas, java.lang.StringBuilder sbNewas, java.lang.StringBuilder sbDelta, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
This method finds clusters in this property graph (treated as undirected).
|
void |
findClusterCleanup(java.lang.StringBuilder sbClusters, java.lang.StringBuilder sbUndir, java.lang.StringBuilder sbCluas, java.lang.StringBuilder sbNewas, java.lang.StringBuilder sbDelta, java.lang.String szOptions)
This method does cleanup work after running graph cluster detection.
|
void |
findClusterPrep(java.lang.StringBuilder sbClusters, java.lang.StringBuilder sbUndir, java.lang.StringBuilder sbCluas, java.lang.StringBuilder sbNewas, java.lang.StringBuilder sbDelta, java.lang.String szOptions)
This method does preparation work before running graph cluster detection.
|
java.util.LinkedList<java.lang.String> |
getConstraintNames(java.lang.String szTabName)
Gets a List of all the database constraints associated to the given table.
|
java.lang.Long |
getCurrentSCN()
Returns the current SCN by invoking DBMS FLASHBACK API.
|
java.lang.Long |
getCurrentSCNUnsafe()
Returns the current SCN by invoking DBMS FLASHBACK API.
|
java.lang.Class |
getDatatypeClassFromValueObjForTextIndex(java.lang.Object value)
Gets the datatype class from the given value object used when executing a query over a text index
|
int |
getDefaultDOPPerPtn()
Returns the default DOP used for partition-wise scan
|
OracleEdge |
getEdge(java.lang.Object id)
Returns the edge referenced by the object identifier.
|
java.util.Iterator<EdgeChange> |
getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN)
Returns the changes between the given start SCN and end SCN.
|
java.util.Iterator<EdgeChange> |
getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP)
Returns the edge changes between the given start SCN and end SCN.
|
java.util.Iterator<EdgeChange> |
getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts)
Returns the edge changes between the given start SCN and end SCN.
|
java.util.Iterator<EdgeChange> |
getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts, java.lang.String[] keys)
Returns the edge changes between the given start SCN and end SCN.
|
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 |
getEdgePartitionsNumber()
Returns the number of HASH partitions of the edge table.
|
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()
Returns an iterable to all the edges in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdges(boolean bOrderBySVID)
Returns an iterable to all the edges in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdges(boolean bOrderBySVID, java.lang.Long longEndSCN)
Returns an iterable to all the edges in the graph from the given SCN.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdges(boolean bOrderBySVID, java.lang.Long longEndSCN, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns 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.sql.Connection[] connArray)
Returns an array of iterables to all the edges in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID)
Returns an array of iterables to all the edges in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN)
Returns an array of iterables to all the edges in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID)
Returns an array of iterables to all the edges in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String key)
Returns an array of iterables to all the edges in the graph that have a particular key.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys)
Returns an array of iterables to all the edges in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdges(java.lang.Long longEndSCN)
Returns an iterable to all the edges in the graph from the given SCN.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdges(java.sql.ResultSet rs, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns an
Iterable to all the edges from the ResultSet that satisfy the specified edge filter callback. |
java.lang.Iterable<com.tinkerpop.blueprints.Edge> |
getEdges(java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns 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 useLuceneSyntax)
Return an iterable to all matching edges that have a particular key/value property.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesNonPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, java.lang.String[] keys)
Returns an array of iterables to all the edges in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesNonPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, java.lang.String[] keys)
Returns an array of iterables to all the edges in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(java.sql.Connection[] connArray, boolean skipStoreToCache, int startPartitionID)
Returns an array of iterables to all the edges in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(java.sql.Connection[] connArray, boolean bSkipStoreToCache, int startPartitionID, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterables to all the edges in the graph that satisfy the specified edge filter callback.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(java.sql.Connection[] connArray, boolean skipStoreToCache, int startPartitionID, java.lang.String[] keys)
Returns an array of iterables to all the edges in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys)
Returns an array of iterables to all the edges in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterables to all the edges in the graph that satisfy the specified edge filter callback.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, java.lang.String[] keys)
Returns an array of iterables to all the edges in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] |
getEdgesPartitioned(java.sql.ResultSet[] rsArray, boolean bSkipStoreToCache, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterables to all the edges from the given array of ResultSet objects that satisfy the specified edge filter callback.
|
java.lang.String |
getEdgeTabIdxName(java.lang.String szCode)
Returns the name of an index of the edge table for the specified code
|
java.lang.String |
getEdgeTabName()
Returns the name of the edge table
|
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.
|
java.lang.String |
getGraphName()
Returns the name of this property graph instance
|
java.lang.String |
getGraphOwner()
Returns the owner name of the graph.
|
java.util.LinkedList<java.lang.String> |
getIndexNames(java.lang.String szTabName)
Gets a List of all the database indexes associated to the given table.
|
<T extends com.tinkerpop.blueprints.Element> |
getIndexParameters(java.lang.String indexName, java.lang.Class<T> indexClass)
Gets the index parameters associated to the given text index.
|
static OraclePropertyGraph |
getInstance(Oracle oracle, java.lang.String szGraphName)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szTBSSet, java.lang.String szOptions)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle, java.lang.String szGraphOwner, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(Oracle oracle, java.lang.String szGraphOwner, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szTBSSet, java.lang.String szOptions)
Returns an instance of OraclePropertyGraph using the Oracle connection and graph name provided.
|
static OraclePropertyGraph |
getInstance(oracle.pgx.config.PgRdbmsGraphConfig config)
Gets an OraclePropertyGraph instance from a PGX PgRdbmsGraphConfig object
|
java.util.Set<java.lang.Long> |
getInvalidEdgeIDSet(int dop, ProgressListener pl)
Gets a set of invalid edges that are stored in the property graph.
|
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.
|
java.lang.String |
getNumberToCharSqlFormatString()
Gets the Char SQL Format used to format a number into a string
|
long |
getOperationQueueSize()
Get the size of the operation queue
|
Oracle |
getOracle()
Returns the underlying Oracle instance associated with the property graph instance
|
static Oracle |
getOracle(oracle.pgx.config.PgRdbmsGraphConfig config)
Gets an Oracle object from a PGX PgRdbmsGraphConfig object
|
static Oracle |
getOracle(java.lang.String datasourceId)
Gets an Oracle object from a given Datasource Id
|
OracleIndexManager |
getOracleIndexManager()
Gets the Oracle Index Manager associated to this property graph instance.
|
boolean |
getPGViewOnRDFFlag()
Validates if this property graph instance comes from a Property Graph view over RDF data
|
int |
getQueryFetchSize()
Returns the query fetch size when scanning the vertex and edge tables
|
java.util.Iterator<java.lang.Long> |
getRemovedEdges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, java.lang.String szOptions)
Returns an ordered iterator of IDs of Edges that involved in DELETE operations happened between the two given SCNs.
|
java.util.Iterator<java.lang.Long> |
getRemovedVertices(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, java.lang.String szOptions)
Returns an ordered iterator of IDs of Vertices that involved in DELETE operations happened between the two given SCNs.
|
int |
getRowPrefetch()
Returns the number of rows to prefetch when executing a SQL query over the Property graph data tables
|
java.lang.String |
getSessionID()
Returns the current database Session ID
|
int |
getSessionQueryDOP()
Returns the degree of parallel query execution at the session level.
|
java.lang.String |
getSkeletonTabIdxName(java.lang.String szCode)
Returns the name of an index of the graph GT table for the specified code
|
java.lang.String |
getSkeletonTabName()
Returns the name of the graph skeleton table
|
boolean |
getSkipFormNCharSettingForTextQuery()
Returns TRUE if skipFormNCharSettingForTextQuery flag is set, which is the default behavior.
|
java.lang.String |
getSnapshotTabName()
Returns the name of the PGX snapshot table
|
java.lang.String |
getTextIndexDirectoryPrefix()
Returns the name of this property graph instance
|
java.lang.String |
getTextIndexTabName()
Returns the name of the index metadata table
|
java.lang.String |
getTimeToCharSqlFormatString()
Gets the Char SQL Format used to format a datetime into a string
|
static java.sql.ResultSet |
getTopK(java.sql.Connection conn, java.lang.StringBuilder sbTabName, int iColIdx, OraclePropertyGraph.Sort sort, int k, int iDOP)
Returns the top K rows of a given table.
|
java.sql.ResultSet |
getTopK(java.lang.StringBuilder sbTabName, int iColIdx, OraclePropertyGraph.Sort sort, int k)
Returns the top K rows of a given table.
|
java.sql.ResultSet |
getTopK(java.lang.StringBuilder sbTabName, int iColIdx, OraclePropertyGraph.Sort sort, int k, int iDOP)
Returns the top K rows of a given table.
|
OracleVertex |
getVertex(java.lang.Object id)
Returns the vertex referenced by the object identifier.
|
java.util.Iterator<VertexChange> |
getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN)
Returns the changes between the given start SCN and end SCN.
|
java.util.Iterator<VertexChange> |
getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP)
Returns the vertex changes between the given start SCN and end SCN using the given query degree of parallelism.
|
java.util.Iterator<VertexChange> |
getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts)
Returns the vertex changes between the given start SCN and end SCN.
|
java.util.Iterator<VertexChange> |
getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts, java.lang.String[] keys)
Returns the vertex changes between the given start SCN and end SCN.
|
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 |
getVertexPartitionsNumber()
Returns the number of HASH partitions of the vertex table.
|
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.
|
java.lang.String |
getVertexTabIdxName(java.lang.String szCode)
Returns the name of an index of the vertex table for the specified code
|
java.lang.String |
getVertexTabName()
Returns the name of the vertex table
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex> |
getVertices()
Returns an iterable to all the vertices in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVertices(java.sql.Connection[] connArray)
Returns an array of iterables to all the vertices in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVertices(java.sql.Connection[] connArray, java.lang.Long longEndSCN)
Returns an array of iterables to all the vertices in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVertices(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID)
Returns an array of iterables to all the vertices in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVertices(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String key)
Returns an array of iterables to all the vertices in the graph that have a particular key.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVertices(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys)
Returns an array of iterables to all the vertices in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex> |
getVertices(java.lang.Long longEndSCN, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns 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.sql.ResultSet rs, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns an iterable to all the relevant vertices in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex> |
getVertices(java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns 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 useLuceneSyntax)
Return an iterable to all matching vertices that have a particular key/value property.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesNonPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, java.lang.String[] keys)
Returns an array of iterables to all the vertices in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesNonPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, java.lang.String[] keys)
Returns an array of iterables to all the vertices in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(java.sql.Connection[] connArray, boolean skipStoreToCache, int startPartitionID)
Returns an array of iterables to all the vertices in the graph.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(java.sql.Connection[] connArray, boolean skipStoreToCache, int startPartitionID, java.lang.String[] keys)
Returns an array of iterables to all the vertices in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(java.sql.Connection[] connections, boolean bSkipStoreToCache, int startPartitionID, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterables to all the vertices in the graph that satisfy the specified vertex filter callback.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys)
Returns an array of iterables to all the vertices in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys, VertexFilterCallback vfc)
Returns an array of iterables 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>[] |
getVerticesPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterables 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>[] |
getVerticesPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, java.lang.String[] keys)
Returns an array of iterables to all the vertices in the graph that have any of the specified keys.
|
java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] |
getVerticesPartitioned(java.sql.ResultSet[] rsArray, boolean bSkipStoreToCache, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Returns an array of iterables to all the vertices in the graph that satisfy the specified vertex filter callback.
|
java.sql.Date |
getVTE()
Get the end valid time used in the property graph
|
java.sql.Date |
getVTS()
Get the start valid time used in the property graph
|
void |
grantAccess(java.lang.String user, java.lang.String privilege)
Grants access of this property graph to another user
|
void |
impEdgeStat(java.lang.String statTableName, java.lang.String statid)
Imports the edge table statistics from the given stat table.
|
void |
impVertexStat(java.lang.String statTableName, java.lang.String statid)
Imports the vertex table statistics from the given stat table.
|
boolean |
isDB11g()
Returns if this property graph instance is working against an 11g database
|
boolean |
isShardingDb()
This method verifies if the underlying connection is opened against a sharding DB
|
boolean |
isVirtualPropertyGraph()
Validates if this property graph instance is based on a view
|
static long |
pageRank(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbNodePR, java.lang.StringBuilder sbNodeNextPR, java.lang.StringBuilder sbEdgeTabDeg, java.lang.StringBuilder sbDelta, float d, int iNumIterations, float convergence, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
This method calculates the page rank values of vertices in the given graph.
|
long |
pageRank(java.lang.StringBuilder sbNodePR, java.lang.StringBuilder sbNodeNextPR, java.lang.StringBuilder sbEdgeTabDeg, java.lang.StringBuilder sbDelta, float d, int iNumIterations, float convergence, int iDOP, java.lang.String szTBS, java.lang.String szOptions)
This method calculates the page rank values of vertices in this graph.
|
void |
pageRankCleanup(java.lang.StringBuilder sbNodePR, java.lang.StringBuilder sbNodeNextPR, java.lang.StringBuilder sbEdgeTabDeg, java.lang.StringBuilder sbDelta, java.lang.String szOptions)
This method does cleanup work before running page rank calculation.
|
void |
pageRankPrep(java.lang.StringBuilder sbNodePR, java.lang.StringBuilder sbNodeNextPR, java.lang.StringBuilder sbEdgeTabDeg, java.lang.StringBuilder sbDelta, java.lang.String szOptions)
This method does preparation work before running page rank calculation.
|
java.sql.ResultSet[] |
parallelExecuteStatements(java.sql.PreparedStatement[] stmtArray)
Executes the given statements in parallel and returns an array of result sets from each statement.
|
java.lang.String |
parseValueToCharSQLFormatString(java.lang.Object value)
Parses a numeric or datetime value object into the String format required by SQL (Oracle Text) using the CharSQL formats used in this property graph instance.
|
static java.lang.Object |
readObjFromResultSet(java.sql.ResultSet rs, int iIdxTypeCol)
Reads a few columns: T, V, VN, VT from the result set and constructs an Object (V in a K/V pair) depending on the actual object type.
|
void |
rebuildAllIndexPartitions(java.lang.String szIdx, int iDop)
Rebuilds all the index partitions for the given database index.
|
void |
rebuildEdgeTableConstraints(java.util.List<java.lang.String> llConstraints, int dop, java.lang.String szOptions)
This method rebuilds all the database constraints of the edge table.
|
void |
rebuildEdgeTableIndices(java.util.List<java.lang.String> llIndices, int dop, java.lang.String szOptions)
Rebuilds all database indices of the edge table.
|
void |
rebuildVertexTableConstraints(java.util.List<java.lang.String> llConstraints, int dop, java.lang.String szOptions)
Rebuilds all the database constraints of the vertex table.
|
void |
rebuildVertexTableIndices(java.util.List<java.lang.String> llIndices, int dop, java.lang.String szOptions)
Rebuilds all database indices of the vertex table.
|
void |
refreshIndices(long lStartSCN, long lEndSCN)
Refreshes all the text indices based on the changes done during the given SCN window.
|
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)
Removes the provided edge from the graph.
|
void |
removeVertex(com.tinkerpop.blueprints.Vertex vertex)
Removes the provided vertex from the graph.
|
void |
rollback()
Rollbacks the operations done to this property graph instance
|
void |
setDefaultDOPPerPtn(int i)
This method sets the default DOP used for partition-wise scan.
|
void |
setLabel(java.lang.String policy, java.lang.String label)
Sets the label for the current session.
|
void |
setNumberToCharSqlFormatString(java.lang.String format)
Sets the Char SQL Format used to format a number into a string
|
void |
setPGViewOnRDFFlag(boolean flag)
Specifies if this property graph instance comes from a Property Graph view over RDF data
|
void |
setQueryFetchSize(int size)
Sets the query fetch size used when scanning the vertex and edge tables
|
void |
setRowLabel(java.lang.String policy, java.lang.String label)
Sets the row label for the current session.
|
void |
setRowPrefetch(int i)
Sets the number of rows to prefetch when executing a SQL query over the Property graph data tables
|
void |
setSessionQueryDOP(int dop)
Sets the degree of parallel query execution at the session level.
|
void |
setSkipFormNCharSettingForTextQuery(java.lang.String s)
This method sets a flag for skipFormNCharSettingForTextQuery
|
void |
setTimeToCharSqlFormatString(java.lang.String format)
Sets the Char SQL Format used to format a datetime into a string
|
void |
setVTE(java.sql.Date dateVTE)
Set the end valid time used in the property graph
|
void |
setVTS(java.sql.Date dateVTS)
Set the start valid time used in the property graph
|
static java.lang.String |
shortestPath(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.Long lStart, java.lang.Long lEnd, java.lang.StringBuilder sbExpTab, java.lang.StringBuilder sbPathWeights, java.lang.String szOptions, java.lang.Long lSCN)
Returns a shortest path in a string format.
|
java.lang.String |
shortestPath(java.lang.Long lStart, java.lang.Long lEnd, java.lang.StringBuilder sbExpTab)
Returns a shortest path in a string format.
|
java.lang.String |
shortestPath(java.lang.Long lStart, java.lang.Long lEnd, java.lang.StringBuilder sbExpTab, java.lang.StringBuilder sbPathWeights, java.lang.String szOptions)
Returns a shortest path in a string format.
|
java.lang.String |
shortestPath(java.lang.Long lStart, java.lang.Long lEnd, java.lang.StringBuilder sbExpTab, java.lang.String szEdgeTabName, java.lang.StringBuilder sbPathWeights, java.lang.String szOptions, java.lang.Long lSCN)
Returns a shortest path in a string format.
|
java.lang.String |
shortestPath(OracleVertex vStart, OracleVertex vEnd, java.lang.StringBuilder sbExpTab)
Returns a shortest path in a string format.
|
java.lang.String |
shortestPath(OracleVertex vStart, OracleVertex vEnd, java.lang.StringBuilder sbExpTab, java.lang.StringBuilder sbPathWeights, java.lang.String szOptions)
Returns a shortest path in a string format.
|
void |
shortestPathCleanup(java.lang.StringBuilder sbExpTab, java.lang.String szOptions)
This method does clean up after running shortest path calculations.
|
void |
shortestPathPrep(java.lang.StringBuilder sbExpTab, java.lang.String szOptions)
This method does some preparation work before running one or multiple shortest path calculations.
|
void |
shutdown()
Commits all the queued operations and properly closes the graph.
|
static void |
sparsifyGraph(java.sql.Connection conn, java.lang.String szEdgeTabName, float fThreshold, int iMinKeep, int iDOP, java.lang.StringBuilder sbOutTab, java.lang.StringBuilder sbUndTab, java.lang.StringBuilder sbHshTab, java.lang.StringBuilder sbMchTab, java.lang.String szTBS, java.lang.String szOptions)
This method sparsifies a given graph (treated as undirected).
|
void |
sparsifyGraph(float fThreshold, int iMinKeep, int iDOP, java.lang.StringBuilder sbOutTab, java.lang.StringBuilder sbUndTab, java.lang.StringBuilder sbHshTab, java.lang.StringBuilder sbMchTab, java.lang.String szTBS, java.lang.String szOptions)
This method sparsifies this graph instance (treated as undirected).
|
void |
sparsifyGraphCleanup(java.lang.StringBuilder sbOutTab, java.lang.StringBuilder sbUndTab, java.lang.StringBuilder sbHshTab, java.lang.StringBuilder sbMchTab, java.lang.String szOptions)
This method does cleanup work before running graph sparsification.
|
void |
sparsifyGraphPrep(java.lang.StringBuilder sbOutTab, java.lang.StringBuilder sbUndTab, java.lang.StringBuilder sbHshTab, java.lang.StringBuilder sbMchTab, java.lang.String szOptions)
This method does preparation work before running graph sparsification.
|
java.lang.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, getAdjacentEdgesFromVertices, getAdjacentEdgesFromVertices, getAutoIndex, getBatchSize, getConfig, getDefaultEdgeOptFlag, getDefaultIndexParameters, getDefaultVertexOptFlag, getEdgeFilterCallback, getEdgePropertyNames, getEdges, getEdges, getEdges, getEdges, getEdges, getEdges, getEdges, getEdgesByIds, getEdgesByIds, getEdgesUsingTextSearch, getElementsProperties, getIndex, getIndexedKeys, getIndices, getInvalidEdgeIDSet, getInvalidEdgeIDSet, getJustEdgeIdOptFlag, getJustVertexIdOptFlag, getMaxEdgeID, getMaxEdgeID, getMaxVertexID, getMaxVertexID, getMinEdgeID, getMinEdgeID, getMinVertexID, getMinVertexID, getProgressListener, getQueueSize, getShortestPath, getShortestPath, getSimpleDateFormat, getStringForObj, getVertexFilterCallback, getVertexIDSet, getVertexIDSet, getVertexPropertyNames, getVertices, getVertices, getVertices, getVertices, getVertices, getVertices, getVertices, getVerticesByIds, getVerticesByIds, getVerticesUsingTextSearch, isDisposed, isEdgeAutoIndexEnabled, isEmpty, isShutdown, isTransientPropertyGraphInstance, isVertexAutoIndexEnabled, query, refreshAutoIndices, removeAttributeFromAllEdges, removeAttributeFromAllEdges, removeAttributeFromAllVertices, removeAttributeFromAllVertices, serializableToStr, setBatchSize, setDefaultEdgeOptFlag, setDefaultIndexParameters, setDefaultVertexOptFlag, setEdgeFilterCallback, setProgressListener, setQueueSize, setSolrJavaBinFormat, setTransientPropertyGraphInstance, setVertexFilterCallback, startTransaction, stopTransaction, strToSerializable, sum, useSolrJavaBinFormat
public static final java.lang.String DEFAULT_NUMBER_FORMAT
public static final java.lang.String DEFAULT_TIME_FORMAT
public void addAttributeToAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop, ProgressListener pl)
EdgeOpCallback
. NOTE the current transaction will be committed.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
. NOTE the current transaction will be committed.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 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 void analyze(float estimatePercent, java.lang.String methodOpt) throws java.sql.SQLException
It is very important that up-to-date statistics be maintained for a graph to ensure efficient execution of query. The SQL Optimizer needs accurate information to choose a good execution plan.
After a significant amount of change has been done to a graph, this method should be invoked. Notice that however, statistics collection is a time/resource consuming process, so only run it when necessary.
See Oracle documentation "PL/SQL Packages and Types Reference" for detailed explanations of the parameters.
estimatePercent
- has a valid range of [0.000001,100].methodOpt
- A typical value for methodOpt is "FOR ALL COLUMNS SIZE AUTO"java.sql.SQLException
- when there is error generated from DBMS_STATS package.public void analyze(float estimatePercent, java.lang.String methodOpt, int dop) throws java.sql.SQLException
It is very important that up-to-date statistics be maintained for a graph to ensure efficient execution of query. The SQL Optimizer needs accurate information to choose a good execution plan.
After a significant amount of change has been done to a graph, this method should be invoked. Notice that however, statistics collection is a time/resource consuming process, so only run it when necessary.
See Oracle documentation "PL/SQL Packages and Types Reference" for detailed explanations of the parameters.
estimatePercent
- has a valid range of [0.000001,100].methodOpt
- A typical value for methodOpt is "FOR ALL COLUMNS SIZE AUTO"dop
- degree of parallelism.java.sql.SQLException
- when there is error generated from DBMS_STATS package.public void analyze(int dop) throws java.sql.SQLException
It is very important that up-to-date statistics be maintained for a graph to ensure efficient execution of query. The SQL Optimizer needs accurate information to choose a good execution plan.
After a significant amount of change has been done to a graph, this method should be invoked. Notice that however, statistics collection is a time/resource consuming process, so only run it when necessary.
See Oracle documentation "PL/SQL Packages and Types Reference" for detailed explanations of the parameters.
dop
- degree of parallelism.java.sql.SQLException
- when there is error generated from DBMS_STATS package.public void analyzeAuto(int dop) throws java.sql.SQLException
It is very important that up-to-date statistics be maintained for a graph to ensure efficient execution of query. The SQL Optimizer needs accurate information to choose a good execution plan.
After a significant amount of change has been done to a graph, this method should be invoked. Notice that however, statistics collection is a time/resource consuming process, so only run it when necessary.
See Oracle documentation "PL/SQL Packages and Types Reference" for detailed explanations of the parameters.
dop
- degree of parallelism.java.sql.SQLException
- when there is error generated from DBMS_STATS package.public void clearCache()
clearCache
in class OraclePropertyGraphBase
public void clearRepository() throws java.sql.SQLException
clearRepository
in class OraclePropertyGraphBase
java.sql.SQLException
public void clearUpdateQueue()
public void collaborativeFiltering(java.lang.String szEdgeTabName, java.lang.String szLabel, java.lang.String szRatingProperty, int iterations, double minError, int features, double learningRate, double decreaseRate, double regularizationParam, int dop, java.lang.StringBuilder sbLeft, java.lang.StringBuilder sbRight, java.lang.StringBuilder sbLeft1, java.lang.StringBuilder sbRight1, java.lang.StringBuilder sbMatrixProduct, java.lang.StringBuilder sbLeftDelta, java.lang.StringBuilder sbRightDelta, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
collaborativeFiltering
in interface OraclePropertyGraphAnalytics
szEdgeTabName
- a String with the name of the graph edges table.szLabel
- the label of the edges that hold the rating property.szRatingProperty
- the name of the rating property.iterations
- the maximum number of iterations.minError
- the minimum error to reach to finish the iterations.features
- the number of features for the left and right side products.learningRate
- the learning rate for the gradient descent.decreaseRate
- the decrease rate if the learning rate is too big for the intermediate error.regularizationParam
- an additional parameter to avoid over fitting.dop
- degree of paralellism.sbLeft
- a place holder for the name of the working table that holds the left side factor of the matrix factorization.sbRight
- a place holder for the name of the working table that holds the right side factor of the matrix factorization.sbLeft1
- a place holder for the name of the working table that holds the left side intermediate step in the gradient descent.sbRight1
- a place holder for the name of the working table that holds the right side intermediate step in the gradient descent.sbMatrixProduct
- a place holder for the name of the working table that holds intermediate matrix product.sbLeftDelta
- a place holder for the name of the working table that holds intermediate left side delta in gradient descent.sbRightDelta
- a place holder for the name of the working table that holds intermediate right side delta in gradient descent.szTBS
- the name of the tablespace. It can be null.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public java.lang.Double collaborativeFilteringCheckIntermediateError(double regularizationParam, int dop, java.lang.StringBuilder sbMatrixProduct) throws java.sql.SQLException
regularizationParam
- the additional parameter to avoid over fitting.dop
- degree of paralellism.sbMatrixProduct
- a place holder for the name of the working table that holds intermediate matrix product.java.sql.SQLException
public void collaborativeFilteringCleanup(java.lang.String szEdgeTabName, java.lang.StringBuilder sbLeft, java.lang.StringBuilder sbRight, java.lang.StringBuilder sbLeft1, java.lang.StringBuilder sbRight1, java.lang.StringBuilder sbMatrixProduct, java.lang.StringBuilder sbLeftDelta, java.lang.StringBuilder sbRightDelta, java.lang.String szOptions) throws java.sql.SQLException
collaborativeFilteringCleanup
in interface OraclePropertyGraphAnalytics
szEdgeTabName
- a String with the name of the graph edges tablesbLeft
- a place holder for the name of the working table that holds the left side factor of the matrix factorizationsbRight
- a place holder for the name of the working table that holds the right side factor of the matrix factorizationsbLeft1
- a place holder for the name of the working table that holds the left side intermediate step in the gradient descentsbRight1
- a place holder for the name of the working table that holds the right side intermediate step in the gradient descentsbMatrixProduct
- a place holder for the name of the working table that holds intermediate matrix productsbLeftDelta
- a place holder for the name of the working table that holds intermediate left side delta in gradient descentsbRightDelta
- a place holder for the name of the working table that holds intermediate right side delta in gradient descentszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public java.lang.Double collaborativeFilteringGetRecommendation(java.lang.String szEdgeTabName, int dop, long srcVertex, long dstVertex, java.lang.StringBuilder sbLeft, java.lang.StringBuilder sbRight) throws java.sql.SQLException
szEdgeTabName
- a String with the name of the graph edges table.dop
- degree of paralellism.srcVertex
- the source vertex to the make the recommendation for (e.g. a customer vertex)dstVertex
- the destination vertex of the recommendation (e.g. a product vertex)sbLeft
- a place holder for the name of the working table that holds the left side factor of the matrix factorization.sbRight
- a place holder for the name of the working table that holds the right side factor of the matrix factorization.java.sql.SQLException
public void collaborativeFilteringPrep(java.lang.String szEdgeTabName, java.lang.StringBuilder sbLeft, java.lang.StringBuilder sbRight, java.lang.StringBuilder sbLeft1, java.lang.StringBuilder sbRight1, java.lang.StringBuilder sbMatrixProduct, java.lang.StringBuilder sbLeftDelta, java.lang.StringBuilder sbRightDelta, java.lang.String szOptions) throws java.sql.SQLException
collaborativeFilteringPrep
in interface OraclePropertyGraphAnalytics
szEdgeTabName
- a String with the name of the graph edges tablesbLeft
- a place holder for the name of the working table that holds the left side factor of the matrix factorizationsbRight
- a place holder for the name of the working table that holds the right side factor of the matrix factorizationsbLeft1
- a place holder for the name of the working table that holds the left side intermediate step in the gradient descentsbRight1
- a place holder for the name of the working table that holds the right side intermediate step in the gradient descentsbMatrixProduct
- a place holder for the name of the working table that holds intermediate matrix productsbLeftDelta
- a place holder for the name of the working table that holds intermediate left side delta in gradient descentsbRightDelta
- a place holder for the name of the working table that holds intermediate right side delta in gradient descentszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void commit()
commit
in interface com.tinkerpop.blueprints.TransactionalGraph
public void commit(boolean bCommitIndices)
public long countEdges(int dop, ProgressListener pll)
countEdges
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the edges.public static long countTriangle(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbUndirWorkTab, int iNumSubPtns, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
conn
- a JDBC Connection instanceszEdgeTabName
- name of the edge table (or view)sbUndirWorkTab
- a place holder for the name of the undirected working table to be used for calculating triangles. This argument is relevant when "CREATE_UNDIRECTED=T" option is set.iNumSubPtns
- has to be a positive integer and has to be power of two. This value represents the number of logical partitions chosen to do the calculation. Set the value to 1 to avoid using partitioned approach.iDOP
- degree of parallelism to be usedszTBS
- tablespace. It can be NULL.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public long countTriangle(java.lang.StringBuilder sbUndirWorkTab) throws java.sql.SQLException
countTriangle
in interface OraclePropertyGraphAnalytics
sbUndirWorkTab
- a place holder for the name of the undirected working table to be used for calculating triangles.java.sql.SQLException
public long countTriangle(java.lang.StringBuilder sbUndirWorkTab, int iNumSubPtns, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
countTriangle
in interface OraclePropertyGraphAnalytics
sbUndirWorkTab
- a place holder for the name of the undirected working table to be used for calculating triangles. This argument is relevant when "CREATE_UNDIRECTED=T" option is set.iNumSubPtns
- has to be a positive integer and has to be power of two. This value represents the number of logical partitions chosen to do the calculation. Set the value to 1 to avoid using partitioned approach.iDOP
- degree of parallelism to be usedszTBS
- tablespace. It can be NULL.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void countTriangleCleanup(java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, java.lang.String szOptions) throws java.sql.SQLException
countTriangleCleanup
in interface OraclePropertyGraphAnalytics
sbUndirBMTab
- a place holder for the name of the undirected working table (before mapping) to be used for calculating triangles.sbMapWorkTab
- a place holder for the name of the map working table to be used for calculating triangles.sbUndirAMTab
- a place holder for the name of the undirected working table (after mapping) to be used for calculating triangles.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void countTrianglePrep(java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, java.lang.String szOptions) throws java.sql.SQLException
countTrianglePrep
in interface OraclePropertyGraphAnalytics
sbUndirBMTab
- a place holder for the name of the undirected working table (before mapping) to be used for calculating triangles.sbMapWorkTab
- a place holder for the name of the map working table to be used for calculating triangles. The map working table is for renumbering vertices.sbUndirAMTab
- a place holder for the name of the undirected working table (after mapping) to be used for calculating triangles.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public static long countTriangleRenum(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, int iNumSubPtns, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
conn
- a JDBC connection to Oracle DatabaseszEdgeTabName
- name of a graph edge table (or view)sbUndirBMTab
- a place holder for the name of the undirected working table (before mapping) to be used for calculating triangles.sbMapWorkTab
- a place holder for the name of the map working table to be used for calculating triangles.sbUndirAMTab
- a place holder for the name of the undirected working table (after mapping) to be used for calculating triangles.iNumSubPtns
- has to be a positive integer and has to be power of two. This value represents the number of logical partitions chosen to do the calculation. Set the value to 1 to avoid using partitioned approach.iDOP
- degree of parallelism to be used for creating a working table holding undirected graph data and for executing triangle counting query.szTBS
- tablespace. It can be NULL.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public long countTriangleRenum(java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, int iNumSubPtns, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
countTriangleRenum
in interface OraclePropertyGraphAnalytics
sbUndirBMTab
- a place holder for the name of the undirected working table (before mapping) to be used for calculating triangles.sbMapWorkTab
- a place holder for the name of the map working table to be used for calculating triangles.sbUndirAMTab
- a place holder for the name of the undirected working table (after mapping) to be used for calculating triangles.iNumSubPtns
- has to be a positive integer and has to be power of two. This value represents the number of logical partitions chosen to do the calculation. Set the value to 1 to avoid using partitioned approach.iDOP
- degree of parallelism to be used for creating a working table holding undirected graph data and for executing triangle counting query.szTBS
- tablespace. It can be NULL.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public long countVertices(int dop, ProgressListener pll)
countVertices
in class OraclePropertyGraphBase
dop
- a positive integer defining the number of threads to use when parallel scanning the vertices.pll
- a ProgressListener object.public void createDefaultSpatialIndexOnEdges(int dop) throws java.sql.SQLException
dop
- degree of parallelism used to create the Spatial indexjava.sql.SQLException
public void createDefaultSpatialIndexOnEdges(int dop, boolean bLocal, boolean bUseV2) throws java.sql.SQLException
dop
- degree of parallelism used to create the Spatial indexbLocal
- creates a local index if truebUseV2
- uses MDSYS.SPATIAL_INDEX_V2 as the indextype if true, and uses MDSYS.SPATIAL_INDEX as the indextype if false.java.sql.SQLException
public void createDefaultSpatialIndexOnVertices(int dop) throws java.sql.SQLException
dop
- degree of parallelism used to create the Spatial indexjava.sql.SQLException
public void createDefaultSpatialIndexOnVertices(int dop, boolean bLocal, boolean bUseV2) throws java.sql.SQLException
dop
- degree of parallelism used to create the Spatial indexbLocal
- creates a local index if truebUseV2
- uses MDSYS.SPATIAL_INDEX_V2 as the indextype if true, and uses MDSYS.SPATIAL_INDEX as the indextype if false.java.sql.SQLException
public void createStatTable(java.lang.String statTableName) throws java.sql.SQLException
statTableName
- name of the stat table.java.sql.SQLException
- when there is error generated from DBMS_STATS package.public void disable() throws java.sql.SQLException
disable
in interface OracleChangeTracker
java.sql.SQLException
public java.util.List<java.lang.String> disableEdgeTableConstraints() throws java.sql.SQLException
java.sql.SQLException
public java.util.List<java.lang.String> disableEdgeTableIndices() throws java.sql.SQLException
java.sql.SQLException
public java.util.List<java.lang.String> disableVertexTableConstraints() throws java.sql.SQLException
java.sql.SQLException
public java.util.List<java.lang.String> disableVertexTableIndices() throws java.sql.SQLException
java.sql.SQLException
public void dispose()
public boolean doesEdgeExistAt(java.lang.String szEdgeID, java.lang.Long longEndSCN) throws java.sql.SQLException
doesEdgeExistAt
in interface OracleChangeTracker
szEdgeID
- ID of the edgelongEndSCN
- scnjava.sql.SQLException
public boolean doesEdgeExistAt(java.lang.String szEdgeID, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
doesEdgeExistAt
in interface OracleChangeTracker
szEdgeID
- ID of the edgelongEndSCN
- scniQueryDOP
- the degree of parallelism to be used to do the checkjava.sql.SQLException
public boolean doesVertexExistAt(java.lang.String szVertexID, java.lang.Long longEndSCN) throws java.sql.SQLException
doesVertexExistAt
in interface OracleChangeTracker
szVertexID
- ID of the vertexlongEndSCN
- scnjava.sql.SQLException
public boolean doesVertexExistAt(java.lang.String szVertexID, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
doesVertexExistAt
in interface OracleChangeTracker
szVertexID
- ID of the vertexlongEndSCN
- scniQueryDOP
- the degree of parallelism to be used to do the checkjava.sql.SQLException
public void dropDefaultSpatialIndexOnEdges() throws java.sql.SQLException
java.sql.SQLException
public void dropDefaultSpatialIndexOnVertices() throws java.sql.SQLException
java.sql.SQLException
public void enableAtSCN(java.lang.Long longSCN) throws java.sql.SQLException
enableAtSCN
in interface OracleChangeTracker
longSCN
- SCN of the snapshotjava.sql.SQLException
public static long estimateTriangleRenum(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, int iNumSubPtns, int iChunk, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
sbUndirBMTab
- a place holder for the name of the undirected working table (before mapping) to be used for calculating triangles.sbMapWorkTab
- a place holder for the name of the map working table to be used for calculating triangles.sbUndirAMTab
- a place holder for the name of the undirected working table (after mapping) to be used for calculating triangles.iNumSubPtns
- has to be a positive integer and has to be power of two. This value represents the number of logical partitions chosen to do the calculation. As the number of logical partitions grows, the estimation will become faster (and less precise).iChunk
- an integer in the range of [0, iNumSubPtns*iNumSubPtns - 1]iDOP
- degree of parallelism to be usedszTBS
- tablespace. It can be NULL.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public long estimateTriangleRenum(java.lang.StringBuilder sbUndirBMTab, java.lang.StringBuilder sbMapWorkTab, java.lang.StringBuilder sbUndirAMTab, int iNumSubPtns, int iChunk, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
estimateTriangleRenum
in interface OraclePropertyGraphAnalytics
sbUndirBMTab
- a place holder for the name of the undirected working table (before mapping) to be used for calculating triangles.sbMapWorkTab
- a place holder for the name of the map working table to be used for calculating triangles.sbUndirAMTab
- a place holder for the name of the undirected working table (after mapping) to be used for calculating triangles.iNumSubPtns
- has to be a positive integer and has to be power of two. This value represents the number of logical partitions chosen to do the calculation. As the number of logical partitions grows, the estimation will become faster (and less precise).iChunk
- an integer in the range of [0, iNumSubPtns*iNumSubPtns - 1]iDOP
- degree of parallelism to be usedszTBS
- tablespace. It can be NULL.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void expEdgeStat(java.lang.String statTableName, java.lang.String statid) throws java.sql.SQLException
statTableName
- name of the stat table.statid
- identifier of statisticsjava.sql.SQLException
- when there is error generated from DBMS_STATS package.public void expVertexStat(java.lang.String statTableName, java.lang.String statid) throws java.sql.SQLException
statTableName
- name of the stat table.statid
- identifier of statisticsjava.sql.SQLException
- when there is error generated from DBMS_STATS package.public static void findCluster(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbClusters, java.lang.StringBuilder sbUndir, java.lang.StringBuilder sbCluas, java.lang.StringBuilder sbNewas, java.lang.StringBuilder sbDelta, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
conn
- a JDBC connection to Oracle DatabaseszEdgeTabName
- name of the edge table (or view). Note that one can create a view on top of existing edge table to filter out unwanted edges.sbClusters
- a place holder for the name of the output table that holds cluster assignment for verticessbUndir
- a place holder for the name of the working table that holds undirected graphsbCluas
- a place holder for the name of the working table that holds intermediate cluster assignmentsbNewas
- a place holder for the name of the working table that holds updated cluster assignmentsbDelta
- a place holder for the name of the working table that holds delta informationszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void findCluster(java.lang.StringBuilder sbClusters, java.lang.StringBuilder sbUndir, java.lang.StringBuilder sbCluas, java.lang.StringBuilder sbNewas, java.lang.StringBuilder sbDelta, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
findCluster
in interface OraclePropertyGraphAnalytics
sbClusters
- a place holder for the name of the output table that holds cluster assignment for verticessbUndir
- a place holder for the name of the working table that holds undirected graphsbCluas
- a place holder for the name of the working table that holds intermediate cluster assignmentsbNewas
- a place holder for the name of the working table that holds updated cluster assignmentsbDelta
- a place holder for the name of the working table that holds delta informationszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void findClusterCleanup(java.lang.StringBuilder sbClusters, java.lang.StringBuilder sbUndir, java.lang.StringBuilder sbCluas, java.lang.StringBuilder sbNewas, java.lang.StringBuilder sbDelta, java.lang.String szOptions) throws java.sql.SQLException
findClusterCleanup
in interface OraclePropertyGraphAnalytics
sbClusters
- a place holder for the name of the output table that holds cluster assignment for verticessbUndir
- a place holder for the name of the working table that holds undirected graphsbCluas
- a place holder for the name of the working table that holds intermediate cluster assignmentsbNewas
- a place holder for the name of the working table that holds updated cluster assignmentsbDelta
- a place holder for the name of the working table that holds delta informationszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void findClusterPrep(java.lang.StringBuilder sbClusters, java.lang.StringBuilder sbUndir, java.lang.StringBuilder sbCluas, java.lang.StringBuilder sbNewas, java.lang.StringBuilder sbDelta, java.lang.String szOptions) throws java.sql.SQLException
findClusterPrep
in interface OraclePropertyGraphAnalytics
sbClusters
- a place holder for the name of the output table that holds cluster assignment for verticessbUndir
- a place holder for the name of the working table that holds undirected graphsbCluas
- a place holder for the name of the working table that holds intermediate cluster assignmentsbNewas
- a place holder for the name of the working table that holds updated cluster assignmentsbDelta
- a place holder for the name of the working table that holds delta informationszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public java.util.LinkedList<java.lang.String> getConstraintNames(java.lang.String szTabName) throws java.sql.SQLException
szTabName
- the name of the tablejava.sql.SQLException
public java.lang.Long getCurrentSCN() throws java.sql.SQLException
getCurrentSCN
in interface OracleChangeTracker
java.sql.SQLException
public java.lang.Long getCurrentSCNUnsafe() throws java.sql.SQLException
java.sql.SQLException
public java.lang.Class getDatatypeClassFromValueObjForTextIndex(java.lang.Object value)
getDatatypeClassFromValueObjForTextIndex
in class OraclePropertyGraphBase
public int getDefaultDOPPerPtn()
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 java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN) throws java.sql.SQLException
getEdgeChanges
in interface OracleChangeTracker
longStartSCN
- start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.longEndSCN
- end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.java.sql.SQLException
public java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
getEdgeChanges
in interface OracleChangeTracker
longStartSCN
- start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.longEndSCN
- end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.iQueryDOP
- the degree of parallelism to be used to identify changes.java.sql.SQLException
public java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts) throws java.sql.SQLException
getEdgeChanges
in interface OracleChangeTracker
longStartSCN
- start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.longEndSCN
- end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.iQueryDOP
- the degree of parallelism to be used to identify changes.bFilterOutRemovedInserts
- if an insert has already been removed by the end of time period, then do not include it in the iterator.java.sql.SQLException
public java.util.Iterator<EdgeChange> getEdgeChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts, java.lang.String[] keys) throws java.sql.SQLException
longStartSCN
- start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.longEndSCN
- end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.iQueryDOP
- the degree of parallelism to be used to identify changes.bFilterOutRemovedInserts
- if an insert has already been removed by the end of time period, then do not include it in the iterator.java.sql.SQLException
public 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 getEdgePartitionsNumber() throws java.sql.SQLException
java.sql.SQLException
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()
getEdges
in interface com.tinkerpop.blueprints.Graph
getEdges
in class OraclePropertyGraphBase
public java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdges(boolean bOrderBySVID)
bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.public java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdges(boolean bOrderBySVID, java.lang.Long longEndSCN)
longEndSCN
- the end SCN to read edges frombOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.public java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdges(boolean bOrderBySVID, java.lang.Long longEndSCN, 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.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.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges fromefc
- 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.sql.Connection[] connArray)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges frompublic java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cachepublic java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String key)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].key
- name of the property. It can be NULL which implies all edges in the graph will be returned.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cachepublic java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdges(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cachekeys
- 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> getEdges(java.lang.Long longEndSCN)
longEndSCN
- the end SCN to read edges frompublic java.lang.Iterable<com.tinkerpop.blueprints.Edge> getEdges(java.sql.ResultSet rs, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
to all the edges from the ResultSet that satisfy the specified edge filter callback. The information read back from the edges will be complete or partial based on the optimization flag specified.rs
- the resultset where the edges will be read from.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 NULLl which implies the edges created must be complete.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 useLuceneSyntax)
getEdges
in class OraclePropertyGraphBase
key
- the name of the property. It MUST not be NULL.value
- the value of the property. It can be NULL which will cause all edges with the given key to be returned.dtClass
- the class representing the datatype of the property value. This can be used to cast the property value to a different datatype. For example, if the value is "3.01" and dtClass is Float.Class, then this value will be treated as a 3.01f. If dtClass is set to NULL, then the query will be executed by trying to match the value object to all the supported datatypes.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.useLuceneSyntax
- specifies if the value object is using an Apache Lucene Syntax (further details on Apache Lucene Syntax can be found in https://lucene.apache.org/core/2_9_4/queryparsersyntax.html). If the automatic index is not enabled ahd this flag is set to true, an Exception will be thrown as Lucene Syntax is not supported for database lookups.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesNonPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges frombSkipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cachekeys
- 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>[] getEdgesNonPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges fromkeys
- 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>[] getEdgesPartitioned(java.sql.Connection[] connArray, boolean skipStoreToCache, int startPartitionID)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.startPartitionID
- the ID of the starting partitionskipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cachepublic java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(java.sql.Connection[] connArray, boolean bSkipStoreToCache, int startPartitionID, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.startPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cacheflag
- 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.efc
- an EdgeFilterCallback
object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(java.sql.Connection[] connArray, boolean skipStoreToCache, int startPartitionID, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.startPartitionID
- the ID of the starting partitionskipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cachekeys
- 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>[] getEdgesPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cachekeys
- 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>[] getEdgesPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cachekeys
- an array of property key names. It can be NULL which implies all edges in the graph will be returned.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.efc
- an EdgeFilterCallback
object.public java.lang.Iterable<com.tinkerpop.blueprints.Edge>[] getEdgesPartitioned(java.sql.Connection[] connArray, boolean bOrderBySVID, java.lang.Long longEndSCN, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the edge table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bOrderBySVID
- if true, the iterator will be further ordered by the SVID column value.longEndSCN
- the end SCN to read edges fromkeys
- 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>[] getEdgesPartitioned(java.sql.ResultSet[] rsArray, boolean bSkipStoreToCache, EdgeFilterCallback efc, OraclePropertyGraphBase.OptimizationFlag flag)
rsArray
- a ResultSet
arraybSkipStoreToCache
- if true, the edge instances retrieved by the scan will not be saved into cacheflag
- 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.efc
- an EdgeFilterCallback
object.public java.lang.String getEdgeTabIdxName(java.lang.String szCode)
szCode
- the index code namepublic 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()
getFeatures
in interface com.tinkerpop.blueprints.Graph
public java.lang.String getGraphName()
getGraphName
in class OraclePropertyGraphBase
public java.lang.String getGraphOwner()
public java.util.LinkedList<java.lang.String> getIndexNames(java.lang.String szTabName) throws java.sql.SQLException
szTabName
- the name of the tablejava.sql.SQLException
public final <T extends com.tinkerpop.blueprints.Element> OracleIndexParameters getIndexParameters(java.lang.String indexName, java.lang.Class<T> indexClass)
getIndexParameters
in class OraclePropertyGraphBase
indexName
- the name of the manual index to retrieve.indexClass
- the element class that the index is for.OracleIndexParameters
object.public static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName) throws java.sql.SQLException
oracle
- an Oracle
objectszGraphName
- the name of the graphjava.sql.SQLException
public static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum) throws java.sql.SQLException
oracle
- an Oracle
objectszGraphName
- the name of the graphiHashPartitionsNum
- number of hash partitions to be used.java.sql.SQLException
public static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
oracle
- an Oracle
objectszGraphName
- the name of the graphiHashPartitionsNum
- number of hash partitions to be used.iDOP
- degree of parallelism to be used for creating the underlying tables and indices.szTBS
- the tablespace name where the property graph tables will be created.szOptions
- options to be passed on to the underlying OPG_APIS.CREATE_PG API. It can be NULL.java.sql.SQLException
public static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szTBSSet, java.lang.String szOptions) throws java.sql.SQLException
oracle
- an Oracle
objectszGraphName
- the name of the graphiHashPartitionsNum
- number of hash partitions to be used.iDOP
- degree of parallelism to be used for creating the underlying tables and indices.szTBS
- the tablespace name where the property graph tables will be created.szTBSSet
- the tablespace set name where the property graph tables will be created when using a Sharding DBszOptions
- options to be passed on to the underlying OPG_APIS.CREATE_PG API. It can be NULL.java.sql.SQLException
public static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphOwner, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
oracle
- an Oracle
objectszGraphName
- the name of the graphszGraphOwner
- owner of the graph. This may be different from the login schema.iHashPartitionsNum
- number of hash partitions to be used.iDOP
- degree of parallelism to be used for creating the underlying tables and indices.szTBS
- the tablespace name where the property graph tables will be created.szOptions
- options to be passed on to the underlying OPG_APIS.CREATE_PG API. It can be NULL.java.sql.SQLException
public static OraclePropertyGraph getInstance(Oracle oracle, java.lang.String szGraphOwner, java.lang.String szGraphName, int iHashPartitionsNum, int iDOP, java.lang.String szTBS, java.lang.String szTBSSet, java.lang.String szOptions) throws java.sql.SQLException
oracle
- an Oracle
objectszGraphName
- the name of the graphszGraphOwner
- owner of the graph. This may be different from the login schema.iHashPartitionsNum
- number of hash partitions to be used.iDOP
- degree of parallelism to be used for creating the underlying tables and indices.szTBS
- the tablespace name where the property graph tables will be created.szOptions
- options to be passed on to the underlying OPG_APIS.CREATE_PG API. It can be NULL.java.sql.SQLException
public static OraclePropertyGraph getInstance(oracle.pgx.config.PgRdbmsGraphConfig config) throws java.sql.SQLException
config
- the PGX graph config objectjava.sql.SQLException
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 vertices and edges.pl
- a ProgressListener object.public 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 java.lang.String getNumberToCharSqlFormatString()
public long getOperationQueueSize()
public Oracle getOracle()
public static Oracle getOracle(oracle.pgx.config.PgRdbmsGraphConfig config) throws java.sql.SQLException
config
- the PGX graph config objectjava.sql.SQLException
public static Oracle getOracle(java.lang.String datasourceId) throws java.sql.SQLException
java.sql.SQLException
public OracleIndexManager getOracleIndexManager()
getOracleIndexManager
in class OraclePropertyGraphBase
OracleIndexManager
object.public boolean getPGViewOnRDFFlag()
public int getQueryFetchSize()
public java.util.Iterator<java.lang.Long> getRemovedEdges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, java.lang.String szOptions) throws java.sql.SQLException
getRemovedEdges
in interface OracleChangeTracker
longStartSCN
- start SCNlongEndSCN
- end SCNiQueryDOP
- degree of parallelism to be used for the underlying queryszOptions
- hints for the underlying query.java.sql.SQLException
public java.util.Iterator<java.lang.Long> getRemovedVertices(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, java.lang.String szOptions) throws java.sql.SQLException
getRemovedVertices
in interface OracleChangeTracker
longStartSCN
- start SCNlongEndSCN
- end SCNiQueryDOP
- degree of parallelism to be used for the underlying queryszOptions
- hints for the underlying query.java.sql.SQLException
public int getRowPrefetch()
public java.lang.String getSessionID() throws java.sql.SQLException
java.sql.SQLException
public int getSessionQueryDOP()
public java.lang.String getSkeletonTabIdxName(java.lang.String szCode)
szCode
- the index code namepublic java.lang.String getSkeletonTabName()
public boolean getSkipFormNCharSettingForTextQuery()
public java.lang.String getSnapshotTabName()
public java.lang.String getTextIndexDirectoryPrefix()
getTextIndexDirectoryPrefix
in class OraclePropertyGraphBase
public java.lang.String getTextIndexTabName()
public java.lang.String getTimeToCharSqlFormatString()
public static java.sql.ResultSet getTopK(java.sql.Connection conn, java.lang.StringBuilder sbTabName, int iColIdx, OraclePropertyGraph.Sort sort, int k, int iDOP) throws java.sql.SQLException
conn
- a JDBC connection to Oracle DatabasesbTabName
- a place holder for the table nameiColIdx
- the column to be sortedsort
- ASC or DESCk
- k rows to be returned. Note that it is an upper boundiDOP
- degree of parallelism to be usedjava.sql.SQLException
public java.sql.ResultSet getTopK(java.lang.StringBuilder sbTabName, int iColIdx, OraclePropertyGraph.Sort sort, int k) throws java.sql.SQLException
sbTabName
- a place holder for the table nameiColIdx
- the column to be sortedsort
- ASC or DESCk
- k rows to be returned. Note that it is an upper boundjava.sql.SQLException
public java.sql.ResultSet getTopK(java.lang.StringBuilder sbTabName, int iColIdx, OraclePropertyGraph.Sort sort, int k, int iDOP) throws java.sql.SQLException
sbTabName
- a place holder for the table nameiColIdx
- the column to be sortedsort
- ASC or DESCk
- k rows to be returned. Note that it is an upper boundiDOP
- degree of parallelism to be usedjava.sql.SQLException
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.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN) throws java.sql.SQLException
getVertexChanges
in interface OracleChangeTracker
longStartSCN
- start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.longEndSCN
- end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.java.sql.SQLException
public java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP) throws java.sql.SQLException
getVertexChanges
in interface OracleChangeTracker
longStartSCN
- start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.longEndSCN
- end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.iQueryDOP
- the degree of parallelism to be used to identify changes.java.sql.SQLException
public java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts) throws java.sql.SQLException
getVertexChanges
in interface OracleChangeTracker
longStartSCN
- start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.longEndSCN
- end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.iQueryDOP
- the degree of parallelism to be used to identify changes.bFilterOutRemovedInserts
- if an insert has already been removed by the end of time period, then do not include it in the iterator.java.sql.SQLException
public java.util.Iterator<VertexChange> getVertexChanges(java.lang.Long longStartSCN, java.lang.Long longEndSCN, int iQueryDOP, boolean bFilterOutRemovedInserts, java.lang.String[] keys) throws java.sql.SQLException
longStartSCN
- start SCN value. A NULL value will be treated as MINVALUE to the underlying Oracle Database.longEndSCN
- end SCN value. A NULL value will be treated as MAXVALUE to the underlying Oracle Database.iQueryDOP
- the degree of parallelism to be used to identify changes.bFilterOutRemovedInserts
- if an insert has already been removed by the end of time period, then do not include it in the iterator.keys
- an array of property key names. It can be NULL which implies all vertices changes will be returned.java.sql.SQLException
public 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.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 getVertexPartitionsNumber() throws java.sql.SQLException
java.sql.SQLException
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 java.lang.String getVertexTabIdxName(java.lang.String szCode)
szCode
- the index code namepublic java.lang.String getVertexTabName()
public java.lang.Iterable<com.tinkerpop.blueprints.Vertex> getVertices()
getVertices
in interface com.tinkerpop.blueprints.Graph
getVertices
in class OraclePropertyGraphBase
public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVertices(java.sql.Connection[] connArray)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVertices(java.sql.Connection[] connArray, java.lang.Long longEndSCN)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.longEndSCN
- the end SCN to read vertices frompublic java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVertices(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.longEndSCN
- the end SCN to read vertices fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachepublic java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVertices(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String key)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.bSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachelongEndSCN
- the end SCN to read vertices fromiStartPartitionID
- the ID of the starting partitionkey
- name of the property. It can be NULL which implies all edges in the graph will be returned.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVertices(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.longEndSCN
- the end SCN to read vertices fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachekeys
- 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> getVertices(java.lang.Long longEndSCN, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
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
.longEndSCN
- the end SCN to read vertices fromflag
- 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.sql.ResultSet rs, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
rs
- an result set for matching verticesvfc
- an optional VertexFilterCallback objectflag
- an optional OptimizationFlag object to reduce object sizepublic java.lang.Iterable<com.tinkerpop.blueprints.Vertex> getVertices(java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
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
.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex> getVertices(java.lang.String key, java.lang.Object value, java.lang.Class dtClass, boolean acceptWildcard, boolean useLuceneSyntax)
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 class representing the datatype of the property value. This can be used to cast the property value to a different datatype. For example, if the value is "3.01" and dtClass is Float.Class, then this value will be treated as a 3.01f. If dtClass is set to NULL, then the query will be executed by trying to match the value object to all the supported datatypes.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.useLuceneSyntax
- specifies if the value object is using an Apache Lucene Syntax (further details on Apache Lucene Syntax can be found in https://lucene.apache.org/core/2_9_4/queryparsersyntax.html). If the automatic index is not enabled ahd this flag is set to true, an Exception will be thrown as Lucene Syntax is not supported for database lookups.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesNonPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.longEndSCN
- the end SCN to read vertices frombSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachekeys
- 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>[] getVerticesNonPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.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>[] getVerticesPartitioned(java.sql.Connection[] connArray, boolean skipStoreToCache, int startPartitionID)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.startPartitionID
- the ID of the starting partitionskipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachepublic java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(java.sql.Connection[] connArray, boolean skipStoreToCache, int startPartitionID, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.startPartitionID
- the ID of the starting partitionskipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachekeys
- 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>[] getVerticesPartitioned(java.sql.Connection[] connections, boolean bSkipStoreToCache, int startPartitionID, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connections
- a Connection
array used for concurrent querying inside the Oracle property graph.startPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cacheflag
- 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.vfc
- an VertexFilterCallback
object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.longEndSCN
- the end SCN to read vertices fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachekeys
- 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>[] getVerticesPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys, VertexFilterCallback vfc)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.longEndSCN
- the end SCN to read vertices fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachekeys
- an array of property key names. It can be NULL which implies all vertices in the graph will be returned.vfc
- an VertexFilterCallback
object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, boolean bSkipStoreToCache, int iStartPartitionID, java.lang.String[] keys, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array].connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.longEndSCN
- the end SCN to read vertices fromiStartPartitionID
- the ID of the starting partitionbSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cachekeys
- an array of property key names. It can be NULL which implies all vertices in the graph will be returned.flag
- an OptimizationFlag object specifying if a partial or complete vertex object will be returned. It can be NULL which implies the vertices created must be complete.vfc
- an VertexFilterCallback
object.public java.lang.Iterable<com.tinkerpop.blueprints.Vertex>[] getVerticesPartitioned(java.sql.Connection[] connArray, java.lang.Long longEndSCN, java.lang.String[] keys)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.connArray
- a Connection
array used for concurrent querying inside the Oracle property graph.longEndSCN
- the end SCN to read vertices fromkeys
- 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>[] getVerticesPartitioned(java.sql.ResultSet[] rsArray, boolean bSkipStoreToCache, VertexFilterCallback vfc, OraclePropertyGraphBase.OptimizationFlag flag)
Iterable
array uses a separate connection provided to fetch a subset of the results from the corresponding partition. Note that we assign an integer ID (in the range of [0, N - 1]) to all the partitions in the vertex table with N partitions. The subset of partitions queried will consist of those partitions with ID value in the range of [startPartitionID, startPartitionID - 1 + size of connections array]. By default, the startPartitionID is set to 0.rsArray
- a ResultSet
arraybSkipStoreToCache
- if true, the vertex instances retrieved by the scan will not be saved into cacheflag
- 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.vfc
- an VertexFilterCallback
object.public java.sql.Date getVTE()
public java.sql.Date getVTS()
public void grantAccess(java.lang.String user, java.lang.String privilege) throws java.sql.SQLException
user
- name of the userprivilege
- a string representing priviledges. "R" for read, "S" for select, "I" for insert, "D" for delete, and "U" for update. "RIDUS" can be used to grant read, insert, delete, update, and select in one shot.java.sql.SQLException
public void impEdgeStat(java.lang.String statTableName, java.lang.String statid) throws java.sql.SQLException
statTableName
- name of the stat table.statid
- identifier of statisticsjava.sql.SQLException
- when there is error generated from DBMS_STATS package.public void impVertexStat(java.lang.String statTableName, java.lang.String statid) throws java.sql.SQLException
statTableName
- name of the stat table.statid
- identifier of statisticsjava.sql.SQLException
- when there is error generated from DBMS_STATS package.public boolean isDB11g()
public boolean isShardingDb()
public boolean isVirtualPropertyGraph()
public static long pageRank(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.StringBuilder sbNodePR, java.lang.StringBuilder sbNodeNextPR, java.lang.StringBuilder sbEdgeTabDeg, java.lang.StringBuilder sbDelta, float d, int iNumIterations, float convergence, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
conn
- a JDBC connection to Oracle DatabaseszEdgeTabName
- name of a graph edge table (or view)sbNodePR
- a place holder for the name of the working table that holds the page rank values of the verticessbNodeNextPR
- a place holder for the name of the working table that holds the page rank values in the next iterationsbEdgeTabDeg
- a place holder for the name of the working table that holds edges and node degree informationsbDelta
- a place holder for the name of the working table that holds information about some special verticesd
- damping factor, 0.85f is often used.iNumIterations
- number of iterations to perform PR calculations.convergence
- if positive, then continue PR calculations till sum of PR value changes is less than this convergence setting.szOptions
- options to be used by the underlying PL/SQL API.iDOP
- degree of parallelism to be used for creating a working table holding undirected graph data and for executing triangle counting query.szTBS
- tablespace. It can be NULL.java.sql.SQLException
public long pageRank(java.lang.StringBuilder sbNodePR, java.lang.StringBuilder sbNodeNextPR, java.lang.StringBuilder sbEdgeTabDeg, java.lang.StringBuilder sbDelta, float d, int iNumIterations, float convergence, int iDOP, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
pageRank
in interface OraclePropertyGraphAnalytics
sbNodePR
- a place holder for the name of the working table that holds the page rank values of the verticessbNodeNextPR
- a place holder for the name of the working table that holds the page rank values in the next iterationsbEdgeTabDeg
- a place holder for the name of the working table that holds edges and node degree informationsbDelta
- a place holder for the name of the working table that holds information about some special verticesd
- damping factor, 0.85f is often used.iNumIterations
- number of iterations to perform PR calculations.convergence
- if positive, then continue PR calculations till sum of PR value changes is less than this convergence setting.szOptions
- options to be used by the underlying PL/SQL API.iDOP
- degree of parallelism to be used for creating a working table holding undirected graph data and for executing triangle counting query.szTBS
- tablespace. It can be NULL.java.sql.SQLException
public void pageRankCleanup(java.lang.StringBuilder sbNodePR, java.lang.StringBuilder sbNodeNextPR, java.lang.StringBuilder sbEdgeTabDeg, java.lang.StringBuilder sbDelta, java.lang.String szOptions) throws java.sql.SQLException
pageRankCleanup
in interface OraclePropertyGraphAnalytics
sbNodePR
- a place holder for the name of the working table that holds the page rank values of the verticessbNodeNextPR
- a place holder for the name of the working table that holds the page rank values in the next iterationsbEdgeTabDeg
- a place holder for the name of the working table that holds edges and node degree informationsbDelta
- a place holder for the name of the working table that holds information about some special verticesszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void pageRankPrep(java.lang.StringBuilder sbNodePR, java.lang.StringBuilder sbNodeNextPR, java.lang.StringBuilder sbEdgeTabDeg, java.lang.StringBuilder sbDelta, java.lang.String szOptions) throws java.sql.SQLException
pageRankPrep
in interface OraclePropertyGraphAnalytics
sbNodePR
- a place holder for the name of the working table that holds the page rank values of the verticessbNodeNextPR
- a place holder for the name of the working table that holds the page rank values in the next iterationsbEdgeTabDeg
- a place holder for the name of the working table that holds edges and node degree informationsbDelta
- a place holder for the name of the working table that holds information about some special verticesszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public java.sql.ResultSet[] parallelExecuteStatements(java.sql.PreparedStatement[] stmtArray)
stmtArray
- the array of prepared statements to execute in parallel-public java.lang.String parseValueToCharSQLFormatString(java.lang.Object value)
value
- the value to parsepublic static java.lang.Object readObjFromResultSet(java.sql.ResultSet rs, int iIdxTypeCol) throws java.sql.SQLException, java.io.IOException
rs
- a JDBC result setiIdxTypeCol
- the column index (integer) of the data type column (T)java.sql.SQLException
java.io.IOException
public void rebuildAllIndexPartitions(java.lang.String szIdx, int iDop) throws java.sql.SQLException
szIdx
- the name of the indexiDop
- the degree of parallelism used when executing the processjava.sql.SQLException
public void rebuildEdgeTableConstraints(java.util.List<java.lang.String> llConstraints, int dop, java.lang.String szOptions) throws java.sql.SQLException
llConstraints
- a list of constraint namesdop
- degree of parallelismszOptions
- additional SQL options to add as hints during the rebuild.java.sql.SQLException
public void rebuildEdgeTableIndices(java.util.List<java.lang.String> llIndices, int dop, java.lang.String szOptions) throws java.sql.SQLException
llIndices
- a list of index names to rebuilddop
- degree of parallelism used when rebuilding the indicesszOptions
- additonal SQL options used when rebuilding the indices.java.sql.SQLException
public void rebuildVertexTableConstraints(java.util.List<java.lang.String> llConstraints, int dop, java.lang.String szOptions) throws java.sql.SQLException
llConstraints
- a list of constraint namesdop
- degree of parallelismszOptions
- additional SQL options to add as hints during the rebuild.java.sql.SQLException
public void rebuildVertexTableIndices(java.util.List<java.lang.String> llIndices, int dop, java.lang.String szOptions) throws java.sql.SQLException
llIndices
- a list of index names to rebuilddop
- degree of parallelism used when rebuilding the indicesszOptions
- additonal SQL options used when rebuilding the indices.java.sql.SQLException
public void refreshIndices(long lStartSCN, long lEndSCN)
public void removeAttributeFromAllEdges(EdgeOpCallback eoc, boolean skipStoreToCache, int dop, ProgressListener pl)
EdgeOpCallback
. NOTE the current transaction will be committed.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
. NOTE the current transaction will be committed.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)
removeVertex
in interface com.tinkerpop.blueprints.Graph
vertex
- a Vertex
object to be removedpublic void rollback()
rollback
in interface com.tinkerpop.blueprints.TransactionalGraph
rollback
in class OraclePropertyGraphBase
public void setDefaultDOPPerPtn(int i)
i
- default DOP used for partition-wise scan. It MUST NOT be negative.public void setLabel(java.lang.String policy, java.lang.String label) throws java.sql.SQLException
policy
- name of the OLS policylabel
- security label namejava.sql.SQLException
public void setNumberToCharSqlFormatString(java.lang.String format)
format
- the format used for numeric objectspublic void setPGViewOnRDFFlag(boolean flag)
flag
- use true if this property graph instance comes from a Property Graph view over RDF datapublic void setQueryFetchSize(int size)
size
- the query fetch sizepublic void setRowLabel(java.lang.String policy, java.lang.String label) throws java.sql.SQLException
policy
- name of the OLS policylabel
- security label namejava.sql.SQLException
public void setRowPrefetch(int i)
i
- the prefetch sizepublic void setSessionQueryDOP(int dop) throws java.sql.SQLException
dop
- degree of parallelism. The value can be zero. If the value is negative, then it is no op.java.sql.SQLException
public void setSkipFormNCharSettingForTextQuery(java.lang.String s)
s
- can be "TRUE", "FALSE", or NULL.public void setTimeToCharSqlFormatString(java.lang.String format)
format
- the format used for datetime objectspublic void setVTE(java.sql.Date dateVTE)
public void setVTS(java.sql.Date dateVTS)
public static java.lang.String shortestPath(java.sql.Connection conn, java.lang.String szEdgeTabName, java.lang.Long lStart, java.lang.Long lEnd, java.lang.StringBuilder sbExpTab, java.lang.StringBuilder sbPathWeights, java.lang.String szOptions, java.lang.Long lSCN) throws java.sql.SQLException
conn
- a JDBC connection to Oracle DatabaseszEdgeTabName
- name of the edge table (or view). Note that one can create a view on top of existing edge table to filter out unwanted edges.lStart
- start vertex integer IDlEnd
- destination vertex integer IDsbPathWeights
- place holder of path weights of the shortest path. The first number represents the number of vertices on the shortest path, the second number represents the total weight and the rest numbers denote weights of edges along the shortest path. All these numbers are delimited by spaces.szOptions
- options to be passed on to the underlying PL/SQL API.lSCN
- SCN for the edge table. It can be NULL.java.sql.SQLException
public java.lang.String shortestPath(java.lang.Long lStart, java.lang.Long lEnd, java.lang.StringBuilder sbExpTab) throws java.sql.SQLException
shortestPath
in interface OraclePropertyGraphAnalytics
lStart
- start vertex integer IDlEnd
- destination vertex integer IDsbExpTab
- place holder of expansion table namejava.sql.SQLException
public java.lang.String shortestPath(java.lang.Long lStart, java.lang.Long lEnd, java.lang.StringBuilder sbExpTab, java.lang.StringBuilder sbPathWeights, java.lang.String szOptions) throws java.sql.SQLException
shortestPath
in interface OraclePropertyGraphAnalytics
lStart
- start vertex integer IDlEnd
- destination vertex integer IDsbExpTab
- place holder of expansion table namesbPathWeights
- place holder of path weights of the shortest path. The first number represents the number of vertices on the shortest path, the second number represents the total weight and the rest numbers denote weights of edges along the shortest path. All these numbers are delimited by spaces.szOptions
- options to be passed on to the underlying PL/SQL API.java.sql.SQLException
public java.lang.String shortestPath(java.lang.Long lStart, java.lang.Long lEnd, java.lang.StringBuilder sbExpTab, java.lang.String szEdgeTabName, java.lang.StringBuilder sbPathWeights, java.lang.String szOptions, java.lang.Long lSCN) throws java.sql.SQLException
shortestPath
in interface OraclePropertyGraphAnalytics
lStart
- start vertex integer IDlEnd
- destination vertex integer IDszEdgeTabName
- name of the edge table (or view). Note that one can create a view on top of existing edge table to filter out unwanted edges.sbPathWeights
- place holder of path weights of the shortest path. The first number represents the number of vertices on the shortest path, the second number represents the total weight and the rest numbers denote weights of edges along the shortest path. All these numbers are delimited by spaces.szOptions
- options to be passed on to the underlying PL/SQL API.lSCN
- SCN for the edge table. It can be NULL.java.sql.SQLException
public java.lang.String shortestPath(OracleVertex vStart, OracleVertex vEnd, java.lang.StringBuilder sbExpTab) throws java.sql.SQLException
shortestPath
in interface OraclePropertyGraphAnalytics
vStart
- start vertex objectvEnd
- destination vertex objectsbExpTab
- place holder of expansion table namejava.sql.SQLException
public java.lang.String shortestPath(OracleVertex vStart, OracleVertex vEnd, java.lang.StringBuilder sbExpTab, java.lang.StringBuilder sbPathWeights, java.lang.String szOptions) throws java.sql.SQLException
shortestPath
in interface OraclePropertyGraphAnalytics
vStart
- start vertex objectvEnd
- destination vertex objectsbExpTab
- place holder of expansion table namesbPathWeights
- place holder of path weights of the shortest path. The first number represents the number of vertices on the shortest path, the second number represents the total weight and the rest numbers denote weights of edges along the shortest path. All these numbers are delimited by spaces.szOptions
- options to be passed on to the underlying PL/SQL API.java.sql.SQLException
public void shortestPathCleanup(java.lang.StringBuilder sbExpTab, java.lang.String szOptions) throws java.sql.SQLException
shortestPathCleanup
in interface OraclePropertyGraphAnalytics
sbExpTab
- a place holder for the name of the expansion table to be used for Bi-directional, Set Style, Dijkstra search.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void shortestPathPrep(java.lang.StringBuilder sbExpTab, java.lang.String szOptions) throws java.sql.SQLException
shortestPathPrep
in interface OraclePropertyGraphAnalytics
sbExpTab
- a place holder for the name of the expansion table to be used for Bi-directional, Set Style, Dijkstra search. If sbExpTab is empty, an intermediate working table will be created and the table name will be returned in the sbExpTab object.szOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void shutdown()
shutdown
in interface com.tinkerpop.blueprints.Graph
shutdown
in interface com.tinkerpop.blueprints.TransactionalGraph
public static void sparsifyGraph(java.sql.Connection conn, java.lang.String szEdgeTabName, float fThreshold, int iMinKeep, int iDOP, java.lang.StringBuilder sbOutTab, java.lang.StringBuilder sbUndTab, java.lang.StringBuilder sbHshTab, java.lang.StringBuilder sbMchTab, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
sbOutTab
- a place holder for the name of the output table that holds the sparsified graphsbUndTab
- a place holder for the name of the working table that holds undirected graphsbHshTab
- a place holder for the name of the working table that holds min hash valuessbMchTab
- a place holder for the name of the working table that holds match countsszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void sparsifyGraph(float fThreshold, int iMinKeep, int iDOP, java.lang.StringBuilder sbOutTab, java.lang.StringBuilder sbUndTab, java.lang.StringBuilder sbHshTab, java.lang.StringBuilder sbMchTab, java.lang.String szTBS, java.lang.String szOptions) throws java.sql.SQLException
sbOutTab
- a place holder for the name of the output table that holds the sparsified graphsbUndTab
- a place holder for the name of the working table that holds undirected graphsbHshTab
- a place holder for the name of the working table that holds min hash valuessbMchTab
- a place holder for the name of the working table that holds match countsszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void sparsifyGraphCleanup(java.lang.StringBuilder sbOutTab, java.lang.StringBuilder sbUndTab, java.lang.StringBuilder sbHshTab, java.lang.StringBuilder sbMchTab, java.lang.String szOptions) throws java.sql.SQLException
sbOutTab
- a place holder for the name of the output table that holds the sparsified graphsbUndTab
- a place holder for the name of the working table that holds undirected graphsbHshTab
- a place holder for the name of the working table that holds min hash valuessbMchTab
- a place holder for the name of the working table that holds match countsszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public void sparsifyGraphPrep(java.lang.StringBuilder sbOutTab, java.lang.StringBuilder sbUndTab, java.lang.StringBuilder sbHshTab, java.lang.StringBuilder sbMchTab, java.lang.String szOptions) throws java.sql.SQLException
sbOutTab
- a place holder for the name of the output table that holds the sparsified graphsbUndTab
- a place holder for the name of the working table that holds undirected graphsbHshTab
- a place holder for the name of the working table that holds min hash valuessbMchTab
- a place holder for the name of the working table that holds match countsszOptions
- options to be used by the underlying PL/SQL API.java.sql.SQLException
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2017, 2018 Oracle and/or its affiliates. All Rights Reserved.