leehom commented on issue #500: URL: https://github.com/apache/rocketmq-connect/issues/500#issuecomment-1551480207
> > > @odbozhou 在neo4j为source的时候，假设查询出来的记录都是节点，由于neo4j没有表的概念，所以如果我查出多个标签label的节点（一个标签对应一张表），这样就相当于一次poll会出现多张表的记录，这中情况使用mysql-sink-connector可以正常接受吗 > > > > > > 这种东西交给用户决定，我现在做法是，以目标为导向，就是说，目标的表来源于什么源数据(cql)，这样的话，多标签是映射一个表，还是多个表由用户写的cql决定 > > 那如果是用户写cql的话，查询结果会多样性，例如下面两条都是查询Person标签的节点cql: "MATCH (n:Person) RETURN n limit 100" "MATCH (n:Person) RETURN n.name as name , n.age as age, n.mobile as mobile limit 100 " 这两种查询结果我都要去适配解析成项目中行记录 ConnectRecord吗？ > > 还是说我们制定约束，让用户去选择poll指定标签(label)的节点还是指定类型(type)的关系，最终的cql是我们服务器自己组装的完整cql 用户写cql，首先生成目标库的schema，cql生成结果装填的ConnectRecord column顺序和schema一致，sink端根据schema去读取 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
