schema.vertexLabel("User").
ifNotExists().
partitionBy("uid", Text).
property("name", Text).
create();
schema.vertexLabel("Tweet").
ifNotExists().
partitionBy("text", Text).
create();
schema.edgeLabel("like").
ifNotExists().
from('User').to('Tweet').
create();
users = []
for(i=0; i<5; i++) {
user = g.addV("User").
property("uid", "user" + i).
property("name", "Taro").
next();
users.push(user)
}
tweets = []
for(i=0;i<20; i++) {
tweet = g.addV("Tweet").
property("text", "hello" + i).
next();
tweets.push(tweet)
}
rnd = new Random(2)
for(tweet in tweets) {
for(user in users) {
if (rnd.nextInt() > 0) {
g.addE('like').
from(user).
to(tweet).
next();
}
}
}
dev.V().hasLabel('Tweet').where(inE('like').count().is(gt(2L))).bothE()