Apache Flink: какие вызовы методов вызывают выполнение?

Question

Мне пришлось научиться "трудному пути", используя вызовы методов типа

someDataSet.collect ()

someDataSet.count ()

В середине вашего рабочего процесса flink следует избегать, так как он вызывает преждевременное выполнение кода. Это, конечно, не то, что вы хотите из-за ленивого подхода оценки, который принимает Flink. Есть ли какие-либо другие вызовы методов, которых я должен избегать, потому что они выполняют executeEnvironment.execute () в фоновом режиме?

Answer 1

Интересный вопрос, спасибо:)

Я посмотрел на источник, и только .count() и .collect() звонят .execute(). Но .print() и .printToErr() (и, вероятно, другие методы печати) вызывают .collect(), поэтому они также инициируют немедленное выполнение.