oracle.pg.text.solr

Class SolrVertexIndex

java.lang.Object

oracle.pg.text.solr.SolrIndex<com.tinkerpop.blueprints.Vertex>

oracle.pg.text.solr.SolrVertexIndex

All Implemented Interfaces:

com.tinkerpop.blueprints.Index<com.tinkerpop.blueprints.Vertex>, MesgConsts, OracleIndex<com.tinkerpop.blueprints.Vertex>

public class SolrVertexIndex
extends SolrIndex<com.tinkerpop.blueprints.Vertex>
implements MesgConsts

This class extends the functions defined in SolrIndex. It manages manual indexes defined on Vertex objects using SolrCloud.

Field Summary

Fields inherited from class oracle.pg.text.solr.SolrIndex

EDGE_ID_PROP, TYPE_DT_BOOL, TYPE_DT_BYTE, TYPE_DT_CHAR, TYPE_DT_DATE, TYPE_DT_DOUBLE, TYPE_DT_FLOAT, TYPE_DT_INTEGER, TYPE_DT_JSON, TYPE_DT_LONG, TYPE_DT_SERIALIZABLE, TYPE_DT_SHORT, TYPE_DT_SPATIAL, TYPE_DT_STRING, TYPE_DT_URI, VERSION_PROP, VERTEX_ID_PROP

Fields inherited from interface oracle.pg.common.MesgConsts

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

Fields inherited from interface oracle.pg.text.OracleIndex

EDGE_LABEL_PROP, END_NODE_ID_PROP, m_dtValues, START_NODE_ID_PROP

Method Summary

Modifier and Type	Method and Description
com.tinkerpop.blueprints.CloseableIterable<com.tinkerpop.blueprints.Vertex>	get(java.lang.Object solrQuery) Gets an Iterable object with all the matching elements that match the given query object.
com.tinkerpop.blueprints.CloseableIterable<com.tinkerpop.blueprints.Vertex>	get(java.lang.String key, java.lang.Object value, java.lang.Class dtClass, boolean acceptWildcard) Gets all vertices indexed by the provided key/value.
java.lang.String	getDocIdentifier() Gets the document's identifier associated to this index.
com.tinkerpop.blueprints.CloseableIterable<com.tinkerpop.blueprints.Vertex>[]	getPartitioned(java.lang.Object[] connections, java.lang.Object solrQuery, int startShardId) Gets an array of CloseableIterable objects that hold all the elements with an attribute matching the given K/V pair.
com.tinkerpop.blueprints.CloseableIterable<com.tinkerpop.blueprints.Vertex>[]	getPartitioned(java.lang.Object[] connections, java.lang.String key, java.lang.Object value, java.lang.Class dtClass, boolean acceptWildcard, int startShardId) Gets an array of CloseableIterable objects that hold all the elements with an attribute matching the given K/V pair.

Methods inherited from class oracle.pg.text.solr.SolrIndex

add, add, appendDatatypesSuffixToKey, appendDatatypesSuffixToValue, buildSearchTerm, buildSearchTerm, clearIndex, close, commit, commit, count, count, count, dropIndex, get, get, getCloudSolrServer, getDirectoryName, getGraphName, getIndexClass, getIndexName, getIndexParameters, getOracleIndexParameters, getParameters, getPartitioned, getShardsNames, getTotalShards, getTotalShards, put, put, query, query, remove, remove, remove, remove, removeAll

Methods inherited from class java.lang.Object

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

Method Detail

get

public com.tinkerpop.blueprints.CloseableIterable<com.tinkerpop.blueprints.Vertex> get(java.lang.Object solrQuery)

Gets an Iterable object with all the matching elements that match the given query object. This object can be either a String text search query, a SolrQuery object or a QueryResponse from SolrCloud.

Specified by:

get in interface OracleIndex<com.tinkerpop.blueprints.Vertex>

Specified by:

get in class SolrIndex<com.tinkerpop.blueprints.Vertex>

Parameters:

solrQuery - a object representing the text query to execute.

Returns:

a CloseableIterable object.

get

public com.tinkerpop.blueprints.CloseableIterable<com.tinkerpop.blueprints.Vertex> get(java.lang.String key,
                                                                                       java.lang.Object value,
                                                                                       java.lang.Class dtClass,
                                                                                       boolean acceptWildcard)

Gets all vertices indexed by the provided key/value.

Specified by:

get in interface OracleIndex<com.tinkerpop.blueprints.Vertex>

Specified by:

get in class SolrIndex<com.tinkerpop.blueprints.Vertex>

Parameters:

key - the key of the indexed vertices.

value - the value of the indexed vertices.

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.

acceptWildcard - specifies if wild cards can be used in the value object.

Returns:

an iterable of vertices that have a particular key/value in the index.

getDocIdentifier

public java.lang.String getDocIdentifier()

Gets the document's identifier associated to this index.

Specified by:

getDocIdentifier in interface OracleIndex<com.tinkerpop.blueprints.Vertex>

Overrides:

getDocIdentifier in class SolrIndex<com.tinkerpop.blueprints.Vertex>

Returns:

the document's identifier associated to this index.

getPartitioned

public com.tinkerpop.blueprints.CloseableIterable<com.tinkerpop.blueprints.Vertex>[] getPartitioned(java.lang.Object[] connections,
                                                                                                    java.lang.Object solrQuery,
                                                                                                    int startShardId)

Gets an array of CloseableIterable objects that hold all the elements with an attribute matching the given K/V pair. Each element in the CloseableIterable array uses a separate connection provided to fetch a subset of the results from a corresponding SolrCloud shard. Note that we assign an integer ID (in the range of [0, N - 1]) to all the shards in a SolrCloud cluster with N shards. The subset of shards queried will consist of those shards with ID value in the range of [startShardId, startShardId - 1 + size of connections array].

Specified by:

getPartitioned in interface OracleIndex<com.tinkerpop.blueprints.Vertex>

Specified by:

getPartitioned in class SolrIndex<com.tinkerpop.blueprints.Vertex>

Parameters:

connections - an array of connections to the SolrCloud. Each element of this array should be of type CloudSolrServer. See SolrIndex.getCloudSolrServer(long).

solrQuery - a SolrQuery object.

startShardId - the ID of the starting shard.

Returns:

a CloseableIterable object.

getPartitioned

public com.tinkerpop.blueprints.CloseableIterable<com.tinkerpop.blueprints.Vertex>[] getPartitioned(java.lang.Object[] connections,
                                                                                                    java.lang.String key,
                                                                                                    java.lang.Object value,
                                                                                                    java.lang.Class dtClass,
                                                                                                    boolean acceptWildcard,
                                                                                                    int startShardId)

Gets an array of CloseableIterable objects that hold all the elements with an attribute matching the given K/V pair. Each element in the CloseableIterable array uses a separate connection provided to fetch a subset of the results from a corresponding SolrCloud shard. Note that we assign an integer ID (in the range of [0, N - 1]) to all the shards in a SolrCloud cluster with N shards. The subset of shards queried will consist of those shards with ID value in the range of [startShardId, startShardId - 1 + size of connections array].

Specified by:

getPartitioned in interface OracleIndex<com.tinkerpop.blueprints.Vertex>

Specified by:

getPartitioned in class SolrIndex<com.tinkerpop.blueprints.Vertex>

Parameters:

connections - an array of connections to the SolrCloud. Each element of this array should be of type CloudSolrServer. See SolrIndex.getCloudSolrServer(long).

key - the key of a property

value - the value object of the property.

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.

acceptWildcard - specifies if wild cards can be used in the value object.

startShardId - the ID of the starting shard.

Returns:

a CloseableIterable object.