思维导图备注
Apache Flink v1.16 Documentation
首页 AI助手 白天 夜间 BookChat 小程序 小程序 阅读
  • 书签 我的书签
  • 添加书签 添加书签 移除书签 移除书签

Overview

 Github  来源:Flink 浏览 310 扫码 2022-11-07 18:50:40
  • DataStream Formats
    • Available Formats

    DataStream Formats

    Available Formats

    Formats define how information is encoded for storage. Currently these formats are supported:

    • Avro
    • Azure Table
    • Hadoop
    • Parquet
    • Text files
    当前内容版权归 Flink 或其关联方所有，如需对内容或内容相关联开源项目进行关注与资助，请访问 Flink .
    上一篇:
    下一篇:
    • 书签
    • 添加书签 移除书签
    • Apache Flink v2.2 中文文档
    • Apache Flink v2.2 Documentation
    • Apache Flink v2.1 Documentation
    • Apache Flink v2.1 中文文档
    • Apache Flink v2.0 中文文档
    • Apache Flink v2.0 Documentation
    • Apache Flink v1.20 Documentation
    • Apache Flink v1.20 中文文档
    • Apache Flink v1.19 Documentation
    • Apache Flink v1.19 中文文档
    • Apache Flink v1.18 Documentation
    • Apache Flink v1.18 中文文档
    • Apache Flink v1.17 Documentation
    • Apache Flink v1.17 中文文档
    • Apache Flink v1.16 Documentation
    • Apache Flink v1.16 中文文档
    • Apache Flink v1.15 Documentation
    • Apache Flink v1.15 中文文档
    • Apache Flink v1.14 Documentation
    • Apache Flink v1.14 中文文档
    • Apache Flink v1.13 Documentation
    • Apache Flink v1.13 官方中文文档
    • Apache Flink v1.12 Documentation
    • Apache Flink v1.12 官方中文文档
    • Apache Flink v1.11.1 Documentation
    • Apache Flink v1.11.1 官方中文文档
    • Apache Flink 1.10 Documentation
    • Apache Flink v1.10 官方中文文档
    • Apache Flink v1.9 Documentation
    • Apache Flink v1.9 官方中文文档
    • Try Flink
      • First steps
      • Fraud Detection with the DataStream API
      • Real Time Reporting with the Table API
      • Flink Operations Playground
    • Learn Flink
      • Overview
      • Intro to the DataStream API
      • Data Pipelines & ETL
      • Streaming Analytics
      • Event-driven Applications
      • Fault Tolerance
    • Concepts
      • Overview
      • Stateful Stream Processing
      • Timely Stream Processing
      • Flink Architecture
      • Glossary
    • Application Development
      • Project Configuration
        • Overview
        • Using Maven
        • Using Gradle
        • Connectors and Formats
        • Test Dependencies
        • Advanced 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
          • Queryable State
          • State Backends
          • Data Types & Serialization
            • Overview
            • State Schema Evolution
            • Custom State Serialization
            • 3rd Party Serializers
        • User-Defined Functions
        • Operators
          • Overview
          • Windows
          • Joining
          • Process Function
          • Async I/O
        • Data Sources
        • Side Outputs
        • Handling Application Parameters
        • Testing
        • Experimental Features
        • Scala API Extensions
        • Java Lambda Expressions
        • Managing Execution
          • Execution Configuration
          • Program Packaging
          • Parallel Execution
      • Table API & SQL
        • Overview
        • Concepts & Common API
        • DataStream API Integration
        • Streaming Concepts
          • Overview
          • Determinism in Continuous Queries
          • Dynamic Tables
          • Time Attributes
          • Versioned Tables
          • Temporal Table Function
        • Data Types
        • Time Zone
        • Table API
        • SQL
          • SQL
          • Getting Started
          • Queries
            • Overview
            • Hints
            • WITH clause
            • SELECT & WHERE
            • SELECT DISTINCT
            • Windowing TVF
            • Window Aggregation
            • Group Aggregation
            • Over Aggregation
            • Joins
            • Window JOIN
            • Set Operations
            • ORDER BY clause
            • LIMIT clause
            • Top-N
            • Window Top-N
            • Deduplication
            • Window Deduplication
            • Pattern Recognition
          • CREATE Statements
          • DROP Statements
          • ALTER Statements
          • INSERT Statement
          • ANALYZE Statements
          • DESCRIBE Statements
          • EXPLAIN Statements
          • USE Statements
          • SHOW Statements
          • LOAD Statements
          • UNLOAD Statements
          • SET Statements
          • RESET Statements
          • JAR Statements
        • Functions
          • Overview
          • System (Built-in) Functions
          • User-defined Functions
        • Modules
        • Catalogs
        • SQL Client
        • SQL Gateway
          • Overview
          • REST Endpoint
          • HiveServer2 Endpoint
        • 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
          • HiveServer2 Endpoint
        • 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
            • Overview
            • General User-defined Functions
            • Vectorized 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
            • Overview
            • Windows
            • Process Function
          • Data Types
          • State
        • Dependency Management
        • Execution Mode
        • Configuration
        • Debugging
        • Environment Variables
        • FAQ
      • DataSet API (Legacy)
        • Overview
        • Transformations
        • Iterations
        • Zipping Elements
        • Hadoop MapReduce compatibility with Flink
        • Local Execution
        • Cluster Execution
        • Batch Examples
    • Libraries
      • Event Processing (CEP)
      • State Processor API
      • Graphs
        • Overview
        • Graph API
        • Iterative Graph Processing
        • Library Methods
        • Graph Algorithms
        • Graph Generators
        • Bipartite Graph
    • Connectors
      • DataSet Connectors
        • Formats
          • Avro
          • Hadoop
          • Microsoft Azure table
      • DataStream Connectors
        • Overview
        • Fault Tolerance Guarantees
        • Formats
          • Overview
          • Avro
          • Azure Table storage
          • CSV
          • Hadoop
          • JSON
          • Parquet
          • Text files
        • Kafka
        • Cassandra
        • Elasticsearch
        • Firehose
        • Kinesis
        • 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
        • Firehose
        • Kinesis
        • JDBC
        • Elasticsearch
        • FileSystem
        • HBase
        • DataGen
        • Print
        • BlackHole
        • Hive
          • Overview
          • Hive Catalog
          • Hive Read & Write
          • Hive Functions
        • Download
    • Deployment
      • Overview
      • Resource Providers
        • Standalone
          • Overview
          • Working Directory
          • Docker
          • Kubernetes
        • Native Kubernetes
        • YARN
      • Configuration
      • Memory Configuration
        • Set up Flink’s Process Memory
        • Set up TaskManager Memory
        • Set up JobManager Memory
        • Memory Tuning Guide
        • Troubleshooting
        • Migration Guide
        • Network Buffer Tuning
      • Command-Line Interface
      • Elastic Scaling
      • Fine-Grained Resource Management
      • Speculative Execution
      • File Systems
        • Overview
        • Common Configurations
        • Amazon S3
        • Google Cloud Storage
        • Aliyun OSS
        • Azure Blob Storage
        • Plugins
      • High Availability
        • Overview
        • ZooKeeper HA Services
        • Kubernetes HA Services
      • Metric Reporters
      • Security
        • SSL Setup
        • Kerberos
      • REPLs
        • Python REPL
      • Advanced
        • External Resources
        • History Server
        • Logging
    • Operations
      • State & Fault Tolerance
        • Checkpoints
        • Checkpointing under backpressure
        • Savepoints
        • Checkpoints vs. Savepoints
        • State Backends
        • Tuning Checkpoints and Large State
        • Task Failure Recovery
      • Metrics
      • REST API
      • Batch
        • Batch Shuffle
      • Debugging
        • Debugging Windows & Event Time
        • Debugging Classloading
        • Flame Graphs
        • Application Profiling & 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
      • Jobs and Scheduling
      • Task Lifecycle
      • File Systems
    暂无相关搜索结果！

      本文档使用 BookStack 构建

      文章二维码

      手机扫一扫，轻松掌上读

      文档下载

      • 普通下载
      • 下载码下载(免登录无限下载)
      你与大神的距离，只差一个APP
      APP下载
      请下载您需要的格式的文档，随时随地，享受汲取知识的乐趣！
      PDF文档 EPUB文档 MOBI文档
      温馨提示 每天每在网站阅读学习一分钟时长可下载一本电子书，每天连续签到可增加阅读时长
      下载码方式下载：免费、免登录、无限制。 免费获取下载码

      微信小程序阅读

      BookChat 微信小程序阅读
      您与他人的薪资差距，只差一个随时随地学习的小程序

      书签列表

        阅读记录

        阅读进度: 0.00% ( 0/0 ) 重置阅读进度
          欢迎使用AI助手 AI助手
          全屏 缩小 隐藏 清空