org.apache.nifi.graph

Class InMemoryJanusGraphClientService

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.controller.AbstractControllerService

org.apache.nifi.graph.InMemoryJanusGraphClientService

All Implemented Interfaces:

ConfigurableComponent, ControllerService, GraphClientService

public class InMemoryJanusGraphClientService
extends AbstractControllerService
implements GraphClientService

This is an in memory implementation of the GraphClientService using JanusGraph. It should in no way be confused for a production-ready capability. It is intended to provide a fairly realistic environment for testing Gremlin script submission.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.tinkerpop.gremlin.structure.Graph	graph

Fields inherited from interface org.apache.nifi.graph.GraphClientService

LABELS_ADDED, NODES_CREATED, NODES_DELETED, PROPERTIES_SET, RELATIONS_CREATED, RELATIONS_DELETED, ROWS_RETURNED

Constructor Summary

Constructors

Constructor and Description
InMemoryJanusGraphClientService()

Method Summary

Modifier and Type	Method and Description
Map<String,String>	executeQuery(String query, Map<String,Object> parameters, GraphQueryResultCallback handler) Execute the query.
org.apache.tinkerpop.gremlin.structure.Graph	getGraph() Getter for accessing the generated JanusGraph object once the client service is activated in a test.
String	getTransitUrl()
void	onEnabled(ConfigurationContext context)

Methods inherited from class org.apache.nifi.controller.AbstractControllerService

abstractClearConfigContext, abstractStoreConfigContext, disabled, enabled, getConfigurationContext, getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, getProperty, getStateManager, init, initialize, isEnabled

Methods inherited from class org.apache.nifi.components.AbstractConfigurableComponent

customValidate, equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, getSupportedPropertyDescriptors, hashCode, onPropertyModified, toString, validate

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.nifi.controller.ControllerService

initialize, isStateful

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getIdentifier, getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Field Detail

graph

private org.apache.tinkerpop.gremlin.structure.Graph graph

Constructor Detail

InMemoryJanusGraphClientService

public InMemoryJanusGraphClientService()

Method Detail

onEnabled

@OnEnabled
public void onEnabled(ConfigurationContext context)

executeQuery

public Map<String,String> executeQuery(String query,
                                       Map<String,Object> parameters,
                                       GraphQueryResultCallback handler)

Execute the query. This instantiate a new script engine every time to ensure a pristine environment for testing.

Specified by:

executeQuery in interface GraphClientService

Parameters:

query - A gremlin query (Groovy syntax)

parameters - A map of parameters to be injected into the script. This can be structured the way you would expect a REST API call to Gremlin Server.

handler - The callback for parsing the rsponse.

Returns:

Empty map. This API feature is only filled with values typically when dealing with Cypher clients, Neo4J in particular.

getTransitUrl

public String getTransitUrl()

Specified by:

getTransitUrl in interface GraphClientService

getGraph

public org.apache.tinkerpop.gremlin.structure.Graph getGraph()

Getter for accessing the generated JanusGraph object once the client service is activated in a test. The purpose of this is to allow testers to get access to the graph so they can do things like run traversals on it.

Returns:

Tinkerpop Graph object representing the in memory graph database.