Flink学習メモ：ストリーム処理の基本とKafka統合
Flinkは「ストリーム処理」を基盤とした分散処理エンジンで、データが到着次第すぐに処理を行います。これはバッチ処理（例：Spark）とは異なり、マルチスレッドで逐次的に動作します。以下に、テキストファイルから読み込んだ単語をカウントする最小限の例を示します。
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apach ...
6月1日 23:33 投稿