格林-停止创建多个边缘

如何解决格林-停止创建多个边缘

我的情况是随机选择参加比赛的参与者,例如2名。并为比赛创建一个优势(用于更新分数,即,获胜者200分,与会人员100分)。

对于获奖者来说,它运行良好。但是,对于其余的顶点(即参与者),winGift edge正在从参与者到竞争者创建多次。

如果在12名参与者中产生2名获胜者,则获胜者应获得200分,其余参与者应获得100分。并且对于每个获胜者和参与者,都应添加新游戏顶点以及属性gameID(应随机生成)。而且对于具有gameID ...的游戏,我正在获得唯一性违反了约束错误。。我如何创建具有不同gameId的新游戏顶点作为赢家和参与者的属性。 如果我在不添加游戏顶点的情况下尝试查询,那么正在为参与者创建多个wonGift边缘

这是查询:

g.withSideEffect('curTime',1599469059825)
.V().hasLabel('Competition').has('competitionId','competition-OY-KzEt_H')
.has('active',true).as('c')
.project('participantCount','winner').
by(select('c').inE('participatedIn').has('batch',1).has('isEligible',true).count()).
by(select('c').inE('participatedIn').has('batch',true).as('pe')
    .choose(
        has('picked',true),outV().valueMap().fold(),sample(2).property('earlybirdPicked',true).outV().as('winner')
        .sideEffect(select('pe').hasNot('picked').property('picked',false))
        .sideEffect(
            choose(
                select('c').has('competitionType','online'),select('winner')
                .addE('wonGift').property('typeOfGift','points')
                .property('pointsScored',200)
                .property('on',1599469059825).to('c')
                .select('winner')
                .addV('Game')
                .property('gameId',`game-${Math.random()}`)
                .property('pointsScored',200)
                .addE('participates')
                .to('winner')
                .select('c')
                .inE('participatedIn')
                .has('batch',1)
                .has('isEligible',true)
                .has('picked',false)
                .outV().as('participant')
                .addE('wonGift').property('typeOfGift',100)
                .property('on',1599469059825).to('c')
                .select('participant')
                .addV('Game')
                .property('gameId',100)
                .addE('participates')
                .to('participant')
            )
        ).select('winner').valueMap().fold()
    )
)

请在下面找到添加默认数据的脚本:

g.addV('Person').as('1').
property(single,'callingName','Sharath').
  property(single,'personId','zefasdafas').
  addV('Person').as('2').
  property(single,'Raj').
  property(single,'sVzqUTNVkar').
  addV('Person').as('3').
  property(single,'Hima').
  property(single,'ajlsdfj').
  addV('Competition').as('4').
  property(single,'competitionId','ag-competition-sVzVkar').
  property(single,'active',true).
  property(single,'competitionType','online').
  addV('Person').as('5').
  property(single,'Ram').
  property(single,'personID','asdfasewr').
  addV('Person').as('6').
  property(single,'shiva').
  property(single,'98iejalsd').
  addV('Person').as('7').
  property(single,'Andhrew').
  property(single,'aui;lkj').
  addV('Person').as('8').
  property(single,'Naveen').
  property(single,'naedloli').
  addV('Person').as('9').
  property(single,'Euler').
  property(single,'aek,kndal').
  addV('Person').as('10').
  property(single,'Rahul').
  property(single,'rahoil;lj').
  addV('Person').as('11').
  property(single,'Vijay').
  property(single,'vijiouik').
  addV('Person').as('12').
  property(single,'Ravali').
  property(single,'raikjlka').
  addV('Person').as('13').
  property(single,'Sirisha').
  property(single,'siriosjdkl').
  addE('participatedIn').from('2').to('4').
  property('picked',false).
  property('isEligible',true).
  property('batch',1).addE('participatedIn').
  from('1').to('4').property('picked',1).addE('participatedIn').
  from('3').to('4').property('picked',1).addE('participatedIn').
  from('5').to('4').property('picked',1).addE('participatedIn').
  from('6').to('4').property('picked',1).addE('participatedIn').
  from('7').to('4').property('picked',1).addE('participatedIn').
  from('8').to('4').property('picked',1).addE('participatedIn').
  from('9').to('4').property('picked',1).addE('participatedIn').
  from('10').to('4').property('picked',1).addE('participatedIn').
  from('11').to('4').property('picked',1).addE('participatedIn').
  from('12').to('4').property('picked',1).addE('participatedIn').
  from('13').to('4').property('picked',1)

预先感谢

解决方法

我可以看到出了什么问题,但是我不知道您要如何解决。这行:

sample(2).property('earlybirdPicked',true).outV().as('winner')

随机选择两个边,然后为每个边choose('c').inE('participatedIn')进行选择,这当然意味着您将那些“ participatedIn”边重复两次,然后两次addE()。如果您更改为sample(3),则应该使参与者获得100分,甚至可以创建更多次。

一种解决方法是只更新sideEffect()中的“ 200分赢家”,然后再处理“ 100分赢家”。

gremlin> g.withSideEffect('curTime',1599469059825).
......1>   V().hasLabel('Competition').
......2>   has('competitionId','ag-competition-sVzVkar').
......3>   has('active',true).as('c').
......4>   project('participantCount','winner').
......5>     by(inE('participatedIn').has('batch',1).
......6>        has('isEligible',true).count()).
......7>     by(inE('participatedIn').has('batch',1).
......8>        has('isEligible',true).
......9>        choose(has('picked',true),.....10>               outV(),.....11>               sideEffect(hasNot('picked').property('picked',false)).
.....12>               sample(2).property('earlybirdPicked',true).outV().
.....13>               sideEffect(choose(select('c').has('competitionType','online'),.....14>                                 addE('wonGift').
.....15>                                   property('typeOfGift','points').
.....16>                                   property('pointsScored',200).
.....17>                                   property('on',1599469059825).to('c')))).
.....18>        valueMap().fold()).
.....19>   sideEffect(select('c').
.....20>              inE('participatedIn').has('batch',1).has('isEligible',true).has('picked',false).
.....21>              outV().as('participant').
.....22>              addE('wonGift').
.....23>                property('typeOfGift','points').
.....24>                property('pointsScored',100).
.....25>                property('on',1599469059825).to('c'))
==>[participantCount:12,winner:[[callingName:[Sirisha],personID:[siriosjdkl]],[callingName:[Ravali],personID:[raikjlka]]]]
gremlin> g.E().hasLabel('wonGift').elementMap()
==>[id:64,label:wonGift,IN:[id:9,label:Competition],OUT:[id:22,label:Person],pointsScored:100,typeOfGift:points,on:1599469059825]
==>[id:65,OUT:[id:25,on:1599469059825]
==>[id:52,OUT:[id:37,pointsScored:200,on:1599469059825]
==>[id:53,OUT:[id:34,on:1599469059825]
==>[id:54,OUT:[id:28,on:1599469059825]
==>[id:55,OUT:[id:31,on:1599469059825]
==>[id:56,on:1599469059825]
==>[id:57,on:1599469059825]
==>[id:58,OUT:[id:3,on:1599469059825]
==>[id:59,OUT:[id:0,on:1599469059825]
==>[id:60,OUT:[id:6,on:1599469059825]
==>[id:61,OUT:[id:13,on:1599469059825]
==>[id:62,OUT:[id:16,on:1599469059825]
==>[id:63,OUT:[id:19,on:1599469059825]

我认为这可以为您提供正确的边数。我还摆脱了一堆步骤标签和回溯,我认为这使遍历变得更容易阅读。我认为还有更多优化的余地,因为这种方法使您遍历“ participatedIn”边的总数达到了三倍。我想可以将它重组为一次,但这可能会牺牲可读性。您在这里也有一些相当具体的业务逻辑,我试图避免混乱,所以我不想对整体查询结构进行过多修改。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams['font.sans-serif'] = ['SimHei'] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -> systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping("/hires") public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate<String
使用vite构建项目报错 C:\Users\ychen\work>npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)> insert overwrite table dwd_trade_cart_add_inc > select data.id, > data.user_id, > data.course_id, > date_format(
错误1 hive (edu)> insert into huanhuan values(1,'haoge'); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive> show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 <configuration> <property> <name>yarn.nodemanager.res