Как разделить один DataSet на несколько DataSet в API пакетного обновления - PullRequest
0 голосов
/ 15 февраля 2020

Я пишу приложение с использованием DataSet API из Flink 1.9.2. Могу ли я разделить один DataSet на несколько DataSet в API пакетного flink?

Если я использую DataStream API, Flink поддерживает оператор split / select и sideoutput, которые могут реализовать мое требование.

Но если я использую DataSet API, как я могу разделить один DataSet на несколько DataSet в API пакетного обновления?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...