时态表（Temporal Tables） 设计初衷 关联一张版本表 关联一张普通表 时态表 声明版本表 声明版本视图 声明普通表 时态表（Temporal Tables） 时态表（Temporal Table）是一张随时间变化的表 – 在 Flink 中称为动态表 ，时态表中的每条记录都关联了一个或多个时间段，所有的 Flink 表都是时...

Source connector Canal Debezium MySQL Debezium PostgreSQL Debezium MongoDB DynamoDB File Flume Twitter firehose Kafka Kinesis Netty RabbitMQ Sink connector Aerospike ...

Built-in connector Source connector Canal Debezium MySQL Debezium PostgreSQL Debezium MongoDB Debezium Oracle Debezium Microsoft SQL Server DynamoDB File Flume Twitter fir...

Built-in connector Source connector Canal Debezium MySQL Debezium PostgreSQL Debezium MongoDB DynamoDB File Flume Twitter firehose Kafka Kinesis Netty NSQ RabbitMQ Si...

Overview Formats Kafka JDBC Elasticsearch FileSystem HBase DataGen Print BlackHole

Flume Sinks HDFS Sink Hive Sink Logger Sink Avro Sink Thrift Sink IRC Sink File Roll Sink Null Sink HBaseSinks HBaseSink AsyncHBaseSink MorphlineSolrSink ElasticSearchS...

Overview Overview Supported Load Nodes Supported Flink Versions Usage for SQL API Overview Overview Load Nodes is a set of Sink Connectors based on Apache Flink® for loadi...

Overview Overview Supported Load Nodes Supported Flink Versions Usage for SQL API Overview Overview Load Nodes is a set of Sink Connectors based on Apache Flink® for loadi...

Source connector Canal Debezium MySQL Debezium PostgreSQL Debezium MongoDB DynamoDB File Flume Twitter firehose Kafka Kinesis Netty RabbitMQ Sink connector Aerospike ...

Java compatibility Java 8 (deprecated) Java 11 Untested Flink features Untested language features Java 17 Untested Flink features JDK modularization Known issues Java co...