Skip to content

Instantly share code, notes, and snippets.

View mbroecheler's full-sized avatar

Matthias Broecheler mbroecheler

View GitHub Profile
@mbroecheler
mbroecheler / datasqrl-corn-cla.md
Created March 21, 2025 00:55
DataSQRL Acorn Contributor License Agreement

Fiduciary License Agreement 2.0

based on the

Individual Contributor Exclusive License Agreement

(including the Traditional Patent License OPTION)

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 {
@mbroecheler
mbroecheler / gist:1450d1f7fa5d3dc75aab
Last active August 29, 2015 14:07
Making sure cache is faster than embedded BDB
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)])}