Wie konvertiert man den Datenstrom in den Datensatz in flink?

Question

Ich muss den Datenstrom in Datensatz konvertieren, so dass ich Sortiervorgang für den Datensatz ausführen konnte. Wie konvertiert man den Datenstrom in den Datensatz? Ist es möglich in Flink?

Answer 1

Es ist nicht möglich, einen DataSet in einen DataStream umzuwandeln. Die APIs für Batch- und Stream-Verarbeitung sind getrennt. Sie können jedoch die DataStream in eine Datei schreiben und die Datei als DataSet lesen.