Star

Go from … over edge@max

继续这个话题的讨论。

在如下代码中,spark sst generator生成的的key带有version,而value只是pair对组成。
https://github.com/vesoft-inc/nebula/blob/29492fa8aad59008a7ced0e25b80f4d8b6f459a0/src/tools/spark-sstfile-generator/src/main/scala/com/vesoft/tools/SparkSstFileGenerator.scala#L390-L400

那么value中带的版本号是怎么在编码中体现出来的呢

我有看到edge在生成kv时,key的version是时间戳相关的。
https://github.com/vesoft-inc/nebula/blob/29492fa8aad59008a7ced0e25b80f4d8b6f459a0/src/storage/mutate/AddEdgesProcessor.cpp#L17-L20

疑问是:这个version在哪里用到了呢,可以给我一下代码位置么。

目前 SparkSstFileGenerator 是不可用的,数据导入请使用 https://github.com/vesoft-inc/nebula/blob/29492fa8aad59008a7ced0e25b80f4d8b6f459a0/src/tools/spark-sstfile-generator/src/main/scala/com/vesoft/nebula/tools/generator/v2/SparkClientGenerator.scala

这是一种基于语句的导入工具,文件请见:Spark Writer

浙ICP备20010487号