DataStream API | Apache Flink

v2.0-SNAPSHOT

Try Flink
▾
Learn Flink
▾
Concepts
▾
Application Development
▾
- Project Configuration▾
- DataStream API▾
  - Overview
  - Execution Mode (Batch/Streaming)
  - Event Time▾
    - Generating Watermarks
    - Builtin Watermark Generators
  - State & Fault Tolerance▾
    - Working with State
    - The Broadcast State Pattern
    - Checkpointing
    - State Backends
    - Data Types & Serialization▾
  - User-Defined Functions
  - Operators▾
  - Data Sources
  - Side Outputs
  - Handling Application Parameters
  - Testing
  - Experimental Features
  - Java Lambda Expressions
  - Managing Execution▾
- Table API & SQL▾
  - Overview
  - Concepts & Common API
  - DataStream API Integration
  - Streaming Concepts▾
  - Data Types
  - Time Zone
  - Table API
  - SQL▾
  - Materialized Table▾
  - Functions▾
  - Procedures
  - Modules
  - Catalogs
  - Flink JDBC Driver
  - OLAP Quickstart
  - SQL Client
  - SQL Gateway▾
  - Hive Compatibility▾
    - Hive Dialect▾
      - Overview
      - Queries▾
        
        Overview
        
        Sort/Cluster/Distributed By
        
        Group By
        
        Join
        
        Set Operations
        
        Lateral View Clause
        
        Window Functions
        
        Sub-Queries
        
        CTE
        
        Transform Clause
        
        Table Sample
      - CREATE Statements
      - DROP Statements
      - ALTER Statements
      - INSERT Statements
      - Load Data Statements
      - SHOW Statements
      - ADD Statements
      - SET Statements
  - Configuration
  - Performance Tuning
  - User-defined Sources & Sinks
- Python API▾
  - Overview
  - Installation
  - Table API Tutorial
  - DataStream API Tutorial
  - Table API▾
    - Intro to the Python Table API
    - TableEnvironment
    - Operations▾
      - Overview
      - Row-based Operations
    - Data Types
    - System (Built-in) Functions
    - User Defined Functions▾
    - Conversions between PyFlink Table and Pandas DataFrame
    - Conversions between Table and DataStream
    - SQL
    - Catalogs
    - Metrics
    - Connectors
  - DataStream API▾
    - Intro to the Python DataStream API
    - Operators▾
    - Data Types
    - State
  - Dependency Management
  - Execution Mode
  - Configuration
  - Debugging
  - Environment Variables
  - FAQ
Libraries
▾
- Event Processing (CEP)
- State Processor API
Connectors
▾
- DataStream Connectors▾
  - Overview
  - Fault Tolerance Guarantees
  - Formats▾
    - Overview
    - Avro
    - Azure Table storage
    - CSV
    - Hadoop
    - JSON
    - Parquet
    - Text files
  - DataGen
  - Dynamic Kafka
  - Kafka
  - Cassandra
  - DynamoDB
  - Elasticsearch
  - Firehose
  - Kinesis
  - MongoDB
  - Opensearch
  - Prometheus
  - SQS
  - FileSystem
  - RabbitMQ
  - Google Cloud PubSub
  - Hybrid Source
  - Pulsar
  - JDBC
- Table API Connectors▾
  - Overview
  - Formats▾
    - Formats
    - CSV
    - JSON
    - Avro
    - Confluent Avro
    - Protobuf
    - Debezium
    - Canal
    - Maxwell
    - Ogg
    - Parquet
    - Orc
    - Raw
  - Kafka
  - Upsert Kafka
  - DynamoDB
  - Firehose
  - Kinesis
  - MongoDB
  - JDBC
  - Elasticsearch
  - Opensearch
  - FileSystem
  - HBase
  - DataGen
  - Print
  - BlackHole
  - Hive▾
  - Download
Deployment
▾
- Overview
- Java Compatibility
- Resource Providers▾
  - Standalone▾
  - Native Kubernetes
  - YARN
- Configuration
- Memory Configuration▾
- Command-Line Interface
- Elastic Scaling
- Fine-Grained Resource Management
- Speculative Execution
- File Systems▾
- High Availability▾
- Metric Reporters
- Trace Reporters
- REPLs▾
  - Python REPL
- Security▾
- Advanced▾
Operations
▾
- State & Fault Tolerance▾
- Metrics
- Traces
- REST API
- Batch▾
  - Batch Shuffle
  - Recovery job progress from job master failures
- Debugging▾
- Monitoring▾
  - Monitoring Checkpointing
  - Monitoring Back Pressure
- Upgrading Applications and Flink Versions
- Production Readiness Checklist
Flink Development
▾
- Importing Flink into an IDE
- Building Flink from Source
Internals
▾

Project Homepage
JavaDocs
PyDocs

Pick Docs Version

▾

2.0-SNAPSHOT (✓)

v1.20
v1.19

All Versions

中文版

DataStream API

On This Page

This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.

On This Page