Print SQL 커넥터
Print SQL 커넥터 (Print SQL Connector)
Print 커넥터는 싱크(Sink)로, 모든 행을 표준 출력 또는 표준 에러 스트림에 기록할 수 있게 해줍니다. 스트리밍 작업을 쉽게 테스트하고 프로덕션 환경에서 디버깅하는 데 매우 유용합니다. Print 커넥터는 Flink에 내장(built-in)되어 있어 별도로 추가할 필요가 없습니다.
출처: 문서
본문
Print 커넥터는 슬롯(sink)으로 모든 행을 표준 출력 또는 표준 에러 스트림에 기록할 수 있게 해줍니다.
다음과 같은 용도로 설계되었습니다.
- 스트리밍 작업의 쉬운 테스트
- 프로덕션 디버깅에 매우 유용
네 가지 가능한 형식 옵션이 있습니다.
| 출력 형식 | 조건 1 | 조건 2 |
|---|---|---|
PRINT_IDENTIFIER:taskId> output |
PRINT_IDENTIFIER 제공됨 |
parallelism > 1 |
PRINT_IDENTIFIER> output |
PRINT_IDENTIFIER 제공됨 |
parallelism == 1 |
taskId> output |
PRINT_IDENTIFIER 제공되지 않음 |
parallelism > 1 |
output |
PRINT_IDENTIFIER 제공되지 않음 |
parallelism == 1 |
출력 문자열 형식은 "$row_kind(f0,f1,f2…)"이며, row_kind는 RowKind의 짧은 문자열입니다. 예: "+I(1,1)".
Print 커넥터는 내장(built-in)되어 있습니다.
주의: Print 싱크는 런타임 작업에서 레코드를 출력하므로 작업 로그를 관찰해야 합니다.
Print 테이블 만들기
CREATE TABLE print_table (
f0 INT,
f1 INT,
f2 STRING,
f3 DOUBLE
) WITH (
'connector' = 'print'
);
또는 LIKE 절을 사용해 기존 스키마를 기반으로 할 수도 있습니다.
CREATE TABLE print_table WITH ('connector' = 'print')
LIKE source_table (EXCLUDING ALL)
커넥터 옵션 (Connector Options)
| 옵션 (Option) | 필수 (Required) | 기본값 (Default) | 타입 (Type) | 설명 (Description) |
|---|---|---|---|---|
connector |
required | (none) | String | 사용할 커넥터를 지정합니다. 여기서는 'print'여야 합니다. |
print-identifier |
optional | (none) | String | print를 식별하는 메시지이며, 값의 출력에 앞에 붙습니다(prefix). |
standard-error |
optional | false | Boolean | true이면 표준 출력 대신 표준 에러로 출력합니다. |
sink.parallelism |
optional | (none) | Integer | Print 싱크 오퍼레이터의 병렬도를 정의합니다. 기본적으로 프레임워크가 업스트림 체인 오퍼레이터의 병렬도와 동일하게 결정합니다. |