有一些疑问,
1.这个导入支持我当前的版本吗?
2.我看源码最后生成sst文件,然后上传hdfs,并没有入到rockdb,想了解下是已经以我没理解的方式入库了,还是没有写这个代码?如果要入库需要怎么写?
源码如下,
if (part != currentPart) {
if (writer != null) {
writer.close()
val localFile = s"${localPath}/${currentPart}-${taskID}.sst"
HDFSUtils.upload(localFile, s"${remotePath}/${currentPart}")
Files.delete(Paths.get(localFile))
}
currentPart = part
val tmp = s"${localPath}/${currentPart}-${taskID}.sst"
writer = new NebulaSSTWriter(tmp)
writer.prepare()
}
writer.write(key, value)