Apache Flink v1.3-SNAPSHOT

  • 首页

  • 概念
    • 编程模型
    • Distributed Runtime
  • Quickstart
  • Examples
    • Overview
    • Monitoring Wikipedia Edits
    • Batch Examples

  • Project Setup
    • Sample Project in Java
    • Sample Project in Scala
    • Linking with Flink
    • IDE Setup
    • Scala REPL
    • 关联可选模块
    • Running Flink on Windows
    • Building Flink from Source
  • Application Development
    • Basic API Concepts
      • Overview
      • Scala API Extensions
      • Java 8
    • Streaming (DataStream API)
      • Overview
      • Windows
      • Event Time
        • Overview
        • Generating Timestamps / Watermarks
        • 预定义的 Timestamp Extractors / Watermark Emitters
      • Connectors
        • Overview
        • Fault Tolerance Guarantees
        • Kafka
        • Cassandra
        • Kinesis
        • Elasticsearch
        • Rolling File Sink
        • RabbitMQ
        • NiFi
        • Twitter
      • 过程函数
      • Side Outputs
      • Working with State
      • Checkpointing
      • Async I/O
      • Queryable State
    • Batch (DataSet API)
      • Overview
      • Transformations
      • Iterations
      • Zipping Elements
      • Fault Tolerance
      • Python API
      • Connectors
      • Hadoop Compatibility