DataStream API
E711831
DataStream API is Apache Flink’s core streaming abstraction for building stateful, event-driven data processing applications over unbounded and bounded data streams.
Statements (48)
| Predicate | Object |
|---|---|
| instanceOf |
core abstraction in Apache Flink
ⓘ
stream processing API ⓘ |
| developedBy | Apache Flink community NERFINISHED ⓘ |
| domain |
big data
ⓘ
distributed systems ⓘ stream processing ⓘ |
| executionModel | continuous dataflow ⓘ |
| integratesWith |
Flink checkpointing mechanism
ⓘ
Flink runtime NERFINISHED ⓘ Flink savepoints NERFINISHED ⓘ |
| languageBinding |
Java
NERFINISHED
ⓘ
Python NERFINISHED ⓘ Scala NERFINISHED ⓘ |
| license | Apache License 2.0 ⓘ |
| openSource | true ⓘ |
| partOf | Apache Flink NERFINISHED ⓘ |
| precedes | Flink Table API in abstraction level ⓘ |
| programmingModelFor | stateful stream processing ⓘ |
| provides |
access to keyed state
ⓘ
high-level stream transformations ⓘ low-level process functions ⓘ timers for event-time and processing-time callbacks ⓘ |
| supports |
aggregations
ⓘ
bounded data streams ⓘ connectors to external systems ⓘ event time processing ⓘ event-driven applications ⓘ event-time windows ⓘ exactly-once state consistency ⓘ fault tolerance via checkpoints ⓘ ingestion time semantics ⓘ keyed streams ⓘ non-keyed streams ⓘ processing time semantics ⓘ processing-time windows ⓘ session windows ⓘ side outputs ⓘ stateful operators ⓘ stream joins ⓘ transformations ⓘ unbounded data streams ⓘ watermarks ⓘ windowing ⓘ |
| targetUsers | stream processing application developers ⓘ |
| usedFor |
ETL pipelines
ⓘ
continuous data processing ⓘ event-driven microservices ⓘ real-time analytics ⓘ |
Referenced by (1)
Full triples — surface form annotated when it differs from this entity's canonical label.