Package app.ductape.sdk.graph.adapters

Class CosmosGremlinAdapter

java.lang.Object

app.ductape.sdk.graph.adapters.BaseGraphAdapter

app.ductape.sdk.graph.adapters.CosmosGremlinAdapter

public class CosmosGremlinAdapter
extends BaseGraphAdapter

Azure Cosmos DB Gremlin adapter (in-memory stub; Gremlin live via connection URL).

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<Map<String,Object>>	nodes
protected final List<Map<String,Object>>	relationships

Fields inherited from class app.ductape.sdk.graph.adapters.BaseGraphAdapter

connected, connectionOptions, connectionUrl, maxRetries, supportedFeatures

Constructor Summary

Constructors

Constructor	Description
CosmosGremlinAdapter()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	addLabels(Map<String,Object> options)
Map<String,Object>	allPaths(Map<String,Object> options)	TS IAllPathsResult: paths, count/total.
Map<String,Object>	beginTransaction(Map<String,Object> options)
void	commitTransaction(Map<String,Object> transaction)
Map<String,Object>	connect(Map<String,Object> options)
Map<String,Object>	countNodes(Map<String,Object> options)	TS countNodes(labels?, where?, ...) aggregated result { count }.
Map<String,Object>	countRelationships(Map<String,Object> options)	TS countRelationships(types?, where?, ...) aggregated result { count }.
Map<String,Object>	createNode(Map<String,Object> node)
Map<String,Object>	createNodeConstraint(Map<String,Object> options)	TS schema — node constraint DDL.
Map<String,Object>	createNodeIndex(Map<String,Object> options)	TS schema — node index DDL.
Map<String,Object>	createRelationship(Map<String,Object> relationship)
Map<String,Object>	createRelationshipIndex(Map<String,Object> options)	TS schema — relationship index DDL.
void	disconnect()
Map<String,Object>	dropConstraint(String constraintName)	TS schema — drop constraint by canonical name (adapter-specific semantics).
Map<String,Object>	dropIndex(String indexName)	TS schema — drop index by canonical name (adapter-specific semantics).
Map<String,Object>	findConnectedComponents(Map<String,Object> options)	TS IConnectedComponentsResult: components, count.
Map<String,Object>	findNodeById(Object id)	TS findNodeById — wrapped as { node } when present.
List<Map<String,Object>>	findNodes(Map<String,Object> where)
Map<String,Object>	findRelationshipById(Object id)	TS findRelationshipById — wrapped as { relationship } when present.
List<Map<String,Object>>	findRelationships(Map<String,Object> where)
Map<String,Object>	fullTextSearch(Map<String,Object> options)	TS IFullTextSearchResult: nodes, optional scores.
Map<String,Object>	getNeighborhood(Map<String,Object> options)	TS INeighborhoodResult: nodes, relationships, optional depth.
Map<String,Object>	getStatistics()	TS IGraphStatistics.
protected GraphTypes.GraphType	graphType()
Map<String,Object>	listConstraints()
Map<String,Object>	listIndexes()
Map<String,Object>	listLabels()
Map<String,Object>	listRelationshipTypes()
Map<String,Object>	query(Map<String,Object> options)	TS IRawQueryResult: records, optional summary.
Map<String,Object>	removeLabels(Map<String,Object> options)
void	rollbackTransaction(Map<String,Object> transaction)
Map<String,Object>	setLabels(Map<String,Object> options)
Map<String,Object>	shortestPath(Map<String,Object> options)	TS IShortestPathResult: path, found, length, optional totalWeight.
Map<String,Object>	testConnection(Map<String,Object> options)
Map<String,Object>	traverse(Map<String,Object> options)	TS ITraverseResult: optional paths, nodes, relationships, count.
Map<String,Object>	vectorSearch(Map<String,Object> options)	TS IVectorSearchResult: nodes, scores.

Methods inherited from class app.ductape.sdk.graph.adapters.BaseGraphAdapter

attemptReconnect, ensureConnected, executeWithRetry, executeWithRetry, getGraphType, getSupportedFeatures, isConnected, isConnectionError, supportsFeature

Methods inherited from class java.lang.Object

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

Field Details

nodes

protected final List<Map<String,Object>> nodes

relationships

protected final List<Map<String,Object>> relationships

Constructor Details

CosmosGremlinAdapter

public CosmosGremlinAdapter()

Method Details

graphType

protected GraphTypes.GraphType graphType()

connect

public Map<String,Object> connect(Map<String,Object> options)

Specified by:

connect in class BaseGraphAdapter

testConnection

public Map<String,Object> testConnection(Map<String,Object> options)

Specified by:

testConnection in class BaseGraphAdapter

disconnect

public void disconnect()

Specified by:

disconnect in class BaseGraphAdapter

createNode

public Map<String,Object> createNode(Map<String,Object> node)

Specified by:

createNode in class BaseGraphAdapter

findNodes

public List<Map<String,Object>> findNodes(Map<String,Object> where)

Specified by:

findNodes in class BaseGraphAdapter

createRelationship

public Map<String,Object> createRelationship(Map<String,Object> relationship)

Specified by:

createRelationship in class BaseGraphAdapter

findRelationships

public List<Map<String,Object>> findRelationships(Map<String,Object> where)

Specified by:

findRelationships in class BaseGraphAdapter

beginTransaction

public Map<String,Object> beginTransaction(Map<String,Object> options)

Overrides:

beginTransaction in class BaseGraphAdapter

commitTransaction

public void commitTransaction(Map<String,Object> transaction)

Overrides:

commitTransaction in class BaseGraphAdapter

rollbackTransaction

public void rollbackTransaction(Map<String,Object> transaction)

Overrides:

rollbackTransaction in class BaseGraphAdapter

query

public Map<String,Object> query(Map<String,Object> options)

TS IRawQueryResult: records, optional summary.

Overrides:

query in class BaseGraphAdapter

traverse

public Map<String,Object> traverse(Map<String,Object> options)

TS ITraverseResult: optional paths, nodes, relationships, count.

Overrides:

traverse in class BaseGraphAdapter

shortestPath

public Map<String,Object> shortestPath(Map<String,Object> options)

TS IShortestPathResult: path, found, length, optional totalWeight.

Overrides:

shortestPath in class BaseGraphAdapter

allPaths

public Map<String,Object> allPaths(Map<String,Object> options)

TS IAllPathsResult: paths, count/total.

Overrides:

allPaths in class BaseGraphAdapter

getNeighborhood

public Map<String,Object> getNeighborhood(Map<String,Object> options)

TS INeighborhoodResult: nodes, relationships, optional depth.

Overrides:

getNeighborhood in class BaseGraphAdapter

findConnectedComponents

public Map<String,Object> findConnectedComponents(Map<String,Object> options)

TS IConnectedComponentsResult: components, count.

Overrides:

findConnectedComponents in class BaseGraphAdapter

fullTextSearch

public Map<String,Object> fullTextSearch(Map<String,Object> options)

TS IFullTextSearchResult: nodes, optional scores.

Overrides:

fullTextSearch in class BaseGraphAdapter

vectorSearch

public Map<String,Object> vectorSearch(Map<String,Object> options)

TS IVectorSearchResult: nodes, scores.

Overrides:

vectorSearch in class BaseGraphAdapter

getStatistics

public Map<String,Object> getStatistics()

TS IGraphStatistics.

Overrides:

getStatistics in class BaseGraphAdapter

listLabels

public Map<String,Object> listLabels()

Overrides:

listLabels in class BaseGraphAdapter

listRelationshipTypes

public Map<String,Object> listRelationshipTypes()

Overrides:

listRelationshipTypes in class BaseGraphAdapter

listIndexes

public Map<String,Object> listIndexes()

Overrides:

listIndexes in class BaseGraphAdapter

listConstraints

public Map<String,Object> listConstraints()

Overrides:

listConstraints in class BaseGraphAdapter

findNodeById

public Map<String,Object> findNodeById(Object id)

Description copied from class: BaseGraphAdapter

TS findNodeById — wrapped as { node } when present.

Overrides:

findNodeById in class BaseGraphAdapter

findRelationshipById

public Map<String,Object> findRelationshipById(Object id)

Description copied from class: BaseGraphAdapter

TS findRelationshipById — wrapped as { relationship } when present.

Overrides:

findRelationshipById in class BaseGraphAdapter

addLabels

public Map<String,Object> addLabels(Map<String,Object> options)

Overrides:

addLabels in class BaseGraphAdapter

removeLabels

public Map<String,Object> removeLabels(Map<String,Object> options)

Overrides:

removeLabels in class BaseGraphAdapter

setLabels

public Map<String,Object> setLabels(Map<String,Object> options)

Overrides:

setLabels in class BaseGraphAdapter

countNodes

public Map<String,Object> countNodes(Map<String,Object> options)

Description copied from class: BaseGraphAdapter

TS countNodes(labels?, where?, ...) aggregated result { count }.

Overrides:

countNodes in class BaseGraphAdapter

countRelationships

public Map<String,Object> countRelationships(Map<String,Object> options)

Description copied from class: BaseGraphAdapter

TS countRelationships(types?, where?, ...) aggregated result { count }.

Overrides:

countRelationships in class BaseGraphAdapter

createNodeIndex

public Map<String,Object> createNodeIndex(Map<String,Object> options)

Description copied from class: BaseGraphAdapter

TS schema — node index DDL.

Overrides:

createNodeIndex in class BaseGraphAdapter

createNodeConstraint

public Map<String,Object> createNodeConstraint(Map<String,Object> options)

Description copied from class: BaseGraphAdapter

TS schema — node constraint DDL.

Overrides:

createNodeConstraint in class BaseGraphAdapter

createRelationshipIndex

public Map<String,Object> createRelationshipIndex(Map<String,Object> options)

Description copied from class: BaseGraphAdapter

TS schema — relationship index DDL.

Overrides:

createRelationshipIndex in class BaseGraphAdapter

dropIndex

public Map<String,Object> dropIndex(String indexName)

Description copied from class: BaseGraphAdapter

TS schema — drop index by canonical name (adapter-specific semantics).

Overrides:

dropIndex in class BaseGraphAdapter

dropConstraint

public Map<String,Object> dropConstraint(String constraintName)

Description copied from class: BaseGraphAdapter

TS schema — drop constraint by canonical name (adapter-specific semantics).

Overrides:

dropConstraint in class BaseGraphAdapter