Apache Flink Streaming Java provides the Java API for building stateful, event-driven streaming applications.
Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
Minimal example showing how to create a StreamExecutionEnvironment and execute a simple streaming job.
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.datastream.DataStream;
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStream<String> text = env.readTextFile("input.txt");
text.print();
env.execute("Flink Streaming Job");
Upgrade
Version history
Breaking-change detection hasn't run for this library yet.
Audit
Security & dependencies
CVE tracking and dependency tree are planned for a later release.