based on the
Thank you for your interest in contributing to DataSQRL, Inc.'s Acorn ("We" or "Us").
type Query { | |
Events(limit: Int!, offset: Int = 0): [Events!]! | |
EventsLiked(userid: String!): [EventsLiked!]! | |
RecommendedEvents(userid: String!): [RecommendedEvents!] | |
PersonalizedEventSearch(query: String!, userid: String!): [PersonalizedEventSearch!] | |
} | |
interface AbstractEvents { |
IMPORT conference.Events; --import external data | |
IMPORT recAPI.Likes; --import data from API mutation | |
IMPORT recAPI.AddInterest; --import data from API mutation | |
-- import functions | |
IMPORT string.*; | |
IMPORT text.*; | |
IMPORT vector.*; | |
IMPORT time.parseTimestamp; | |
-- clean up event data and compute embedding [2] | |
Events.id := coalesce(CAST(regexExtract(url, '(\d*)$') AS INT),0); |
java.util.ConcurrentModificationException | |
at java.util.HashMap$HashIterator.nextNode(HashMap.java:1429) | |
at java.util.HashMap$KeyIterator.next(HashMap.java:1453) | |
at java.util.Spliterators$IteratorSpliterator.tryAdvance(Spliterators.java:1812) | |
at java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$205(StreamSpliterators.java:294) | |
at java.util.stream.StreamSpliterators$WrappingSpliterator$$Lambda$61/1265053098.getAsBoolean(Unknown Source) | |
at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) | |
at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:169) | |
at java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:300) | |
at java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) |
import com.google.common.collect.HashMultimap; | |
import com.google.common.collect.SetMultimap; | |
import com.tinkerpop.gremlin.process.TraversalStrategy; | |
import java.util.*; | |
/** | |
* @author Matthias Broecheler ([email protected]) | |
*/ | |
public interface SortingTraversalStrategy extends TraversalStrategy { |
gremlin> g = TitanFactory.open("berkeleyje:/tmp/test") | |
==>titangraph[berkeleyje:/tmp/test] | |
gremlin> mgmt = g.getManagementSystem(); | |
==>com.thinkaurelius.titan.graphdb.database.management.ManagementSystem@27c04377 | |
gremlin> id = mgmt.makePropertyKey("uid").dataType(Long.class).make() | |
==>uid | |
gremlin> mgmt.buildIndex('byUID',Vertex.class).addKey(id).buildCompositeIndex() | |
==>com.thinkaurelius.titan.graphdb.database.management.TitanGraphIndexWrapper@14f3c6fc | |
gremlin> mgmt.commit() | |
gremlin> for (int i=0;i<200;i++) { v = g.addVertex([uid:(int)Math.floor(i/2)])} |