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'을 사용해야 해요.

더 알아보기 (Learn more)