Questions tagged [datastax-enterprise-graph]

0

votes
0

answer
4

Views

Writing to DSE graph from EMR

We are trying to write to write to a DSE graph (cassandra) from EMR and keep getting these errors. My JAR is a shaded jar with the byos dependencies. Any help would be appreciated. java.lang.UnsatisfiedLinkError: org.apache.cassandra.utils.NativeLibraryLinux.getpid()J at org.apache.cassandra.utils.N...
mat77
1

votes
1

answer
107

Views

DSEGraphFrame impossible to launch the graph

I have a dse graph in production. I have enabled one node with search and analytics through opscenter. I can successfully launch a gremlin console and run analytic queries with the command: :remote config alias g graphName.a The problem occurs when I try to launch a DSEGraph Frame query using the sc...
Toufic Zayed
1

votes
0

answer
102

Views

gremlin query is too slow in DSE with large data

I have a gremlin query to fetch a few nodes that are related to a particular node. g.V('123').outE().otherV().has('label','secure') The vertex with id 123 has at least 5000 nodes in its outE() with label secure Also the label property is an indexed property for that node type in the graph schema. Th...
zXor
1

votes
1

answer
94

Views

Can't initialize graph on Datastax using Spark

I'm trying to initialize my Datastax graph using Spark as follow : val graphBuilder = spark.dseGraph('GRAPH_NAME') but I have the following exception : Exception in thread 'main' java.lang.NoClassDefFoundError: com/datastax/bdp/graph/impl/element/vertex/id/AbstractVertexIdExternalImpl at com.datasta...
BeginMoh
1

votes
1

answer
477

Views

gremlin query for the last element of multi property value of vertex

I want to modele data using vertex with multi-properties which has meta-properties, for exemple: the multi-property 'date' : [12/12/2012, 13/12/2012, 19/12/2012, 24/12/2012] and meta property for each value of date, for example, date: 12/12/2012 ('alimented' : 'no'). How can I query the vertex to g...
Chahinez Mahiddine
1

votes
1

answer
69

Views

Why isn't it possible to use DSE Authentication with Gremlin Server using the GraphSON serializer?

I'm trying to use the GraphSON serializer with gremlin server on a DSE instance that uses DSE Authentication. Based on the TinkerPop provider docs, upon receiving a 407 result, authentication would be achieved by sending the following request (preceded by the application/json mime header): { 'reques...
1

votes
1

answer
235

Views

Migrating from Titan to DataStax Enterprise Graph

I'm migrating from Titan to Datastax. I have a graph with around 50 million nodes that is composed in Persons, Addresses, Phones, etc I want to calculate a Person node connections (how many persons have the same phone, addresses, etc). In Titan I wrote a Hadoop job that go over al the person nodes a...
CristiC
1

votes
1

answer
274

Views

How to create a graph and its schema without using Datastax Studio but through Java?

I was trying to create my first connection with DSE Graph through java.. public static void main(String args[]){ DseCluster dseCluster = null; try { dseCluster = DseCluster.builder() .addContactPoint('192.168.1.43') .build(); DseSession dseSession = dseCluster.connect(); GraphTraversalSource g = Ds...
Michail Michailidis
1

votes
2

answer
230

Views

Using index in DSE graph

I'm trying to get the list of persons in a datastax graph that have the same address with other persons and the number of persons is between 3 and 5. This is the query: g.V().hasLabel('person').match(__.as('p').out('has_address').as('a').dedup().count().as('nr'),__.as('p').out('has_address').as('a')...
CristiC
1

votes
1

answer
831

Views

illegal cyclic reference involving error with Spark+Scala combine

I'm facing illegal cyclic reference involving error with Spark+Scala combine. Error Ocured during job for '1473170880000000' and Error Message is scala.reflect.internal.Symbols$CyclicReference: illegal cyclic reference involving method srcip at scala.reflect.internal.Symbols$Symbol$$anonfun$info$3.a...
Balaji Reddy
1

votes
1

answer
316

Views

Cassandra Startup Error: DseModule.java:103 - org/apache/spark/util/ByteBufferInputStream. Exiting

I installed Cassandra, DSE after working on DSE Graphs for a while I installed Spark, R. Now I am unable to start DSE. Cassandra process is not starting I tried disabling Spark and so on. Not sure whats the issue! $ /Users/212500500/dse_510/bin/dse cassandra -g -s Server will start with the original...
Darshan Mehta
1

votes
1

answer
129

Views

DataStax Graph Native API vs Fluent API

i have tried both the native api and fluent api for datastax graph in java. i found fluent api more readable since it resembles java's OOP. Native api has less readability in java since basically strings are being appended to create the entire gremlin script. but on the plus side a single call is ma...
Aditya S
1

votes
1

answer
271

Views

Error initializing cluster data

I am getting following error in Opscenter, after some time the issue got resolved itself. Error initializing cluster data: The request to /APP_Live/keyspaces?ksfields=column_families%2Creplica_placement_strategy%2Cstrategy_options%2Cis_system%2Cdurable_writes%2Cskip_repair%2Cuser_types%2Cuser_funct...
Sreeraju V
1

votes
1

answer
77

Views

DSE Graph Database “Is” relation representation in groovy

I am having difficulty, in understanding this Graph. I understand that Org and Persons are vertices and 'has vendor','Has Customer' and 'Has Employee' are the Edges, but i am not able to understand what is meant by 'isMerchant' here in the picture attached the name is quite intuitive, the Org is...
Suresh
1

votes
1

answer
60

Views

Detect Cycles in a DSE graph

Using TinkerPop3 as the interface to a DSE graph. Is there any easy way to detect cycles in a graph or rather not visit an already visited vertex. Specifically in my case, There is a 'GROUP' vertex and there can be a group of groups. I will like to list all 'USERS' in a group of groups.
1

votes
1

answer
30

Views

Specify an edgeLabel in graphML that tinkerpop can understand

I have been struggling to load a graphml in to Tinkerpop3. Graph graphMLGraph = TinkerGraph.open(); graphMLGraph.io(IoCore.graphml()).readGraph(file.getAbsolutePath()); While loading, I want the the edges to have a label. graphTraversalSource.E().toStream().forEach(edge -> { System.out.println(edge....
1

votes
1

answer
30

Views

How do you display a graph's replication factor in the gremlin-console?

I know for DSE graph, in gremlin-console you can create a graph with replication as follows system.graph('graph_name').replication('{'class' : 'NetworkTopologyStrategy', 'dc1' : 3}') But how do you find out about an existing graph's replication?
Glide
1

votes
1

answer
28

Views

Does DseGraphFrame in Java support exporting graphs?

Per DSE docs, vertices and edges can be exported calling g.V().hasLabel('Person').write.json('/tmp/person_v_json') in dse spark. Can the same be achieved using DseGraphFrame for the Java SDK? I want to make sure because I can't finda write() method.
Glide
1

votes
1

answer
115

Views

How can I run OLAP queries using Node.js Driver for DataStax graph?

I would like to run OLAP queries . Im using datastax node.js driver for OLTP queires. How can I run OLAP using node.js ? http://www.datastax.com/dev/blog/nodejs-driver-for-datastax-enterprise
sara
1

votes
1

answer
131

Views

DSE Graph Loader mapping edges

I have to map data from JSON files to DSE. Everything is working just fine, but I didn't find any documentation about the way to map edges connected to different nodes but sharing a same label. Example : [A:Car] -- [OWNER] --> [B:Person] [C:Car] -- [OWNER] --> [D:Company] I've tried different approa...
Nicolas Delaforge
1

votes
1

answer
49

Views

Error loading GraphSON data into a DSE graph with custom vertex ids

I have created a schema with a custom vertex id like: schema.vertexLabel('foo').partitionKey('_id').ifNotExists().create() I then populated a graph with data. Now I'd like to transfer that data to another graph via GraphSON. The new graph instance has the same schema. To do this I first exported th...
gerrard00
1

votes
1

answer
23

Views

Error using DseGraphFrame with querying timestamp field

I have a Person label with a created property defined: schema.propertyKey(“created”).Timestamp().single().create() I get the error below when trying to use DseGraphFrame to filter for the Person label using the created property in dse spark: scala> g.V().hasLabel(“Person”).has(“created”,...
Glide
1

votes
1

answer
378

Views

Gremlin: adding edges between nodes having the same property

I am very new to Gremlin. I am trying to build a graph on DSE graph using Gremlin. I am able to create the vertices: a = graph.addVertex(label, 'label1', 'key', 1) b = graph.addVertex(label, 'label1', 'key', 2) c = graph.addVertex(label, 'label2', 'key', 1) d = graph.addVertex(label, 'label2', 'key'...
phaidara
2

votes
1

answer
920

Views

DSE Graph with Java Driver, how to add edges

I want to build a graph completely with the Datastax Java Driver. I managed to insert vertices, but I have no clue how to add edges to existing vertices. When I run the following code session.executeGraph('parent = g.V().has('businessId','sys-1').next()'); session.executeGraph('child = g.V().has('bu...
Josef Bauer
2

votes
2

answer
55

Views

Create a empty array inside a Gremlin traversal?

This sounds silly but is there a way to create a empty array inside a Gremlin traversal? For the query below: g.V().has('person','name', 'marko').project('a', 'b').by().by() I want to project b as an empty array. I have tried: g.V().has('person','name', 'marko').project('a', 'b').by().by(constant(''...
Glide
1

votes
1

answer
165

Views

How do I “cancel” an error in gremlin-console and continue with the next command without exiting?

In gremlin-console, when I make a syntax error like the example below - where I forgot to the 2nd quotation - I don't know what to type to return me back to the normal prompt gremlin>. Anything I type including Ctrl+C, Ctrl+U will continue the ......2> like below. gremlin> g.V(' ......1> ......1> '...
Glide
6

votes
1

answer
825

Views

Migrating from Neo4J to DataStax Graph DB (DSE)

We have developed custom and proprietary Software for Route Optimization, using Neo4J as our Graph DB. We also developed few plugins and unmanaged Extensions in Java, that implement specific Business Logic whenever search is done on the Graph. Since we are facing severe Performance Issues with Neo4...
Auro
2

votes
1

answer
125

Views

Mixing CQL and Gremlin in one transaction

I have a need to write a log entry (time-series/journal) entry within the context of a transaction of Gremlin mutations in DSE 5.0. Preferably to a separate Cassandra table (a bit of CQL I suppose). I understand that DSE provides some optimizations around time-series with edges, but it feels like i...
Mike Miller
1

votes
1

answer
328

Views

What guarantees are provided by DSE Graph transactions?

DSE Graph supports the Gremlin transaction API , and the docs have some information about transaction-specific options that can be set using the schema config API. The docs don't seem to have a lot of information yet on what a transaction 'means', or what it guarantees. Presumably, they are not ACID...
1

votes
1

answer
80

Views

Why or() queries are not using index in Datastax DSE 5.0.x Graph?

I have created an index on User and on uuid if I do: schema.vertexLabel('User').describe() I get: schema.vertexLabel('User').index('byUuid').materialized().by('uuid').add() When I am running: g.V().hasLabel('User').has('uuid','oneUuid') The index is picked up properly.. but when I do the following:...
3

votes
1

answer
122

Views

DSE graph more threads result in slow response times

I have asked this question before. But asking again with a concrete example. So I have DSE graph running locally on my Mac. I have the simplest possible creation of a vertex and below is the traversal. g.addV('company').property('id', companyId) .property('name', 'company_' + companyId) .property(Ve...
1

votes
1

answer
227

Views

Explain plan in gremlin Tinkerpop3 (DSE graph)

I have written one query which is taking longer than expected time. g.V().hasLabel('Person').has('name','Person1').out('BELONGS').in('HAS').dedup().as('x').in('HAS').filter(__.in('HAS').has('name','App1')).store('y').select('x').dedup().in('HAS').hasLabel('Org').repeat(out()).until(outE().hasLabel('...
Varun Tahin
2

votes
0

answer
86

Views

Streaming all nodes from DSE Graph using Gremlin

I am using DataStax Enterprise Graph and would like to stream all nodes from the graph database to my app using Gremlin. Note: I'm communicating with Gremlin server via a WebSocket using sessions for persistent variables. To do so without pulling all nodes in memory, I first create an iterator on th...
david_p
2

votes
1

answer
94

Views

DSE Graph: traversals that use both secondary and search indexes, why do they hang?

It seems that gremlin traversals which use both secondary and search indexes in the same traversal hang. Why is that? My understanding from the DSE Graph docs on indexing is that the most appropriate index for low-cardinality properties is a secondary index. I have a model with a 'type' property suc...
Leif Halldor Asgeirsson
1

votes
1

answer
154

Views

How to handle supernodes with DSE Graph

I’ve a simple Vertex „url“: schema.vertexLabel('url').partitionKey('url_fingerprint', 'prop1').properties('url_complete').ifNotExists().create() And a edgeLabel called „links“ which connects one url to another. schema.edgeLabel('links').properties('prop1', 'prop2').connection('url', 'url')...
Michael Weber
1

votes
1

answer
214

Views

Iterating a GraphTraversal with GraphFrame causes UnsupportedOperationException Row to Vertex conversion

The following GraphTraversal traversal = gf().E().hasLabel('foo').limit(5); while (traversal.hasNext()) {} causes the following Exception: java.lang.UnsupportedOperationException: Row to Vertex conversion is not supported: Use .df().collect() instead of the iterator at com.datastax.bdp.graph.spark.g...
Glide
1

votes
1

answer
81

Views

Have Gremlin-console show all the methods available for a specific object?

In gremlin-console, is there a way to show all the methods available for a specific object? For example, In gremlin-console if I type g.V().hasLabel('person') and I want to see what methods I can chain/call for the object returned by g.V().hasLabel('person'). How do you do that?
Glide
1

votes
2

answer
156

Views

Gremlin count() query in Datastax is too slow

I have 3 node in datastax enterprise and loaded 65 million vertices and edges on these. when i use dse studio or gremlin console and run gremlin query on my graph the query is too slow. I defined any kind of index and test again but Had no effect. when i run query for example 'g.v().count()' cpu usa...
ahmad
2

votes
2

answer
69

Views

How to remove cyclic vertex list from list of outer vertexes

I am new in dse graph, I want to create gremlin query which gives me list of all vertex which is linked from specified vertex but from this list I want to remove those list which are linked cyclic. e.g. A --> B A --> C A --> D B --> A If I have above relation then I want below vertex list as result...
user3812269
2

votes
1

answer
185

Views

Can vertices in DSE/DataStax graph be represented as key value

I have three questions on DSE graph: Can DSE graph vertices be represented as key,value entities. If yes what is the key and what will be the value? Is there a concept of primary key/index in DSE graph for vertex? If yes how to create that? Is vertex id the primary key/index? Can we have a composite...
sunillp

View additional questions