Я новичок в Финке и Гелли.У нас есть требование выполнять вычисление графа, в то время как сам граф постоянно меняется из-за постепенных обновлений (часто).Поскольку график такой огромный, мы провели некоторое исследование Spark с TinkerPop.Но проблема этого подхода заключается в том, что RDD является неизменным, что делает инкрементные обновления на графике довольно сложными (IndexRDD не поддерживается в течение длительного времени, поэтому мы не хотим идти в этом направлении).Это заставляет нас думать о Флинк и Гелли.Могут ли какие-нибудь эксперты помочь мне ответить на следующие вопросы: 1. Gelly / Flink может обрабатывать инкрементные обновления изначально, верно?Я имею в виду, что обход графа -> мутация графа -> обход графа не требует дополнительных усилий, таких как искра, чтобы перезагрузить весь СДР, верно?Но если так, как согласованность данных поддерживается во Flink?2. Что произойдет, если я обновлю график (например, добавлю ребро, изменим значение вершины) во время обработки вычисления графа?
Большое спасибо