테이블 포맷 개요
테이블 포맷 개요 (Formats)
Flink는 테이블 커넥터와 함께 사용할 수 있는 다양한 테이블 포맷을 제공해요. 테이블 포맷은 이진 데이터를 테이블 컬럼에 어떻게 매핑할지를 정의하는 저장 포맷이에요. Kafka, Kinesis, Filesystem 같은 커넥터와 조합해 메시지 바이트를 구조화된 컬럼으로 해석해요.
출처: 문서
본문
Flink는 테이블 커넥터와 함께 사용할 수 있는 테이블 포맷 집합을 제공해요. 테이블 포맷은 이진 데이터를 테이블 컬럼에 어떻게 매핑할지를 정의하는 저장 포맷이에요.
Flink는 다음 포맷을 지원해요:
| 포맷 (Formats) | 지원 커넥터 (Supported Connectors) |
|---|---|
| CSV | Apache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Amazon Kinesis Data Firehose, Filesystem |
| JSON | Apache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Amazon Kinesis Data Firehose, Filesystem, Elasticsearch |
| Apache Avro | Apache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Amazon Kinesis Data Firehose, Filesystem |
| Confluent Avro | Apache Kafka, Upsert Kafka |
| Protobuf | Apache Kafka |
| Debezium CDC | Apache Kafka, Filesystem |
| Canal CDC | Apache Kafka, Filesystem |
| Maxwell CDC | Apache Kafka, Filesystem |
| OGG CDC | Apache Kafka, Filesystem |
| Apache Parquet | Filesystem |
| Apache ORC | Filesystem |
| Raw | Apache Kafka, Upsert Kafka, Amazon Kinesis Data Streams, Amazon Kinesis Data Firehose, Filesystem |