BlackHole SQL 커넥터
BlackHole SQL 커넥터
BlackHole 커넥터는 들어오는 모든 입력 레코드를 삼켜버리는(Swallow) 커넥터예요. 유닉스 계열 운영체제의 /dev/null 장치와 똑같이 동작한다고 생각하면 이해하기 쉬워요.
BlackHole 커넥터는 주로 다음 목적으로 설계되었어요: 고성능 테스트(high performance testing), 그리고 UDF의 출력을 검증하되 실질적인 Sink는 쓰지 않아도 되는 경우. BlackHole 커넥터는 Flink에 기본 내장(built-in)되어 있어요.
출처: 문서
본문
BlackHole 테이블을 만드는 방법
CREATE TABLE blackhole_table (
f0 INT,
f1 INT,
f2 STRING,
f3 DOUBLE
) WITH (
'connector' = 'blackhole'
);
또는 기존 스키마를 기반으로 LIKE Clause를 사용해서 만들 수도 있어요.
CREATE TABLE blackhole_table WITH ('connector' = 'blackhole')
LIKE source_table (EXCLUDING ALL)
커넥터 옵션 (Connector Options)
| 옵션(Option) | 필수(Required) | 기본값(Default) | 타입(Type) | 설명(Description) |
|---|---|---|---|---|
| connector | required | (none) | String | 어떤 커넥터를 사용할지 지정해요. 여기서는 'blackhole'을 사용해야 해요. |