В приложении с искровым потоком, где выполняется mapWithState?

Question

В искрообразовании, где выполняется mapWithState? Это на водителя или исполнителя?

Answer 1

mapWithState выполнен на каждом из исполнителей. Это этап перетасовки, который заставляет ключи сопоставляться с исполнителями, а затем каждый исполнитель выполняет функцию состояния, указанную в StateSpec.function.