how to store insert data in message store?

[ivivi]

比如 一个batch insert里面有10条数据，那么存储在message store中的是一个写入request还是具体的10条数据
当这个collection有4个shard，也就是4个vchannel，假如对应到2个pchannel
什么时候这10条数据会被hash到4个vchannel中呢？
当有2个DataNode，每个DataNode消费2个vchannel，那么DataNode消费的是一个写入request和里面的10条数据，还是消费到属于自己特定shard的数据呢？

thanks~~~

[yhmo]

大致如下：

[ivivi]

这里还有个小问题
如Deep Dive中所讲 proxy要先通过data coor去申请growing segment的空间，比如这里 id=4，8的两条数据，是不是就要去DataNode1 所管理的vchannel 0 对应的growing segment去申请空间，申请成功后才会写入到对应pchannel，也就是topic中，那么2秒的过期时间又是如何起到作用的？
这里为什么要有一个申请空间的逻辑，如果直接写入pchannel中，会有什么问题吗？
再次感谢~~~

[yhmo]

timetick的同步机制会产生一两秒的延迟是很正常的。申请空间这个事情先做后做无所谓吧，只要保证写入pchennel的数据流入datanode时有地方存放即可，目前的逻辑实现如此，也许有其中的苦衷。代码细节不用过于纠结，每个大版本这些逻辑可能都会大改，就算看懂了几个月之后就变成无效知识。

[ivivi]

感谢大佬的解惑

[xiaofan-luan]

这里还有个小问题 如Deep Dive中所讲 proxy要先通过data coor去申请growing segment的空间，比如这里 id=4，8的两条数据，是不是就要去DataNode1 所管理的vchannel 0 对应的growing segment去申请空间，申请成功后才会写入到对应pchannel，也就是topic中，那么2秒的过期时间又是如何起到作用的？ 这里为什么要有一个申请空间的逻辑，如果直接写入pchannel中，会有什么问题吗？ 再次感谢~~~

这个机制确实在2.6里面有没有了，目前的id和时间戳都是streamnode处负责分配的

[ivivi]

感谢大佬的指点