arrowFlight 테이블 함수

arrowFlight 테이블 함수 (arrowFlight)

Apache Arrow Flight 서버로 노출된 데이터를 읽고 쓸 수 있는 테이블 함수예요.

출처: 문서

본문

Apache Arrow Flight 서버로 노출된 데이터를 읽고 쓸 수 있습니다.

구문

arrowFlight('host:port', 'dataset_name' [, 'username', 'password'])

인자

  • host:port — Arrow Flight 서버의 주소. 포트를 생략하면 기본 포트 8815를 사용합니다. String.
  • dataset_name — Arrow Flight 서버에서 사용 가능한 데이터셋 또는 디스크립터의 이름. String.
  • username — 기본 HTTP 인증용 사용자 이름. String.
  • password — 기본 HTTP 인증용 비밀번호. String.

username과 password를 지정하지 않으면 인증을 사용하지 않습니다(Arrow Flight 서버가 인증 없는 접근을 허용할 때만 동작해요).

이 함수는 named collections도 지원합니다. 지원되는 파라미터 목록은 ArrowFlight 테이블 엔진을 참고해요.

반환 값

원격 데이터셋을 나타내는 테이블 객체. 스키마는 Arrow Flight 서버에서 유추합니다.

설정

  • arrow_flight_request_descriptor_type — 데이터셋 이름을 Flight 서버에 보내는 방식을 제어합니다. 값: path(기본값) 또는 command. 자세한 내용은 ArrowFlight 테이블 엔진을 참고해요.

예제

원격 Arrow Flight 서버에서 읽기:

Query

SELECT * FROM arrowFlight('127.0.0.1:9005', 'sample_dataset') ORDER BY id;

Response

┌─id─┬─name────┬─value─┐
│  1 │ foo     │ 42.1  │
│  2 │ bar     │ 13.3  │
│  3 │ baz     │ 77.0  │
└────┴─────────┴───────┘

원격 Arrow Flight 서버에 데이터 삽입하기:

INSERT INTO FUNCTION arrowFlight('127.0.0.1:9005', 'sample_dataset') VALUES (4, 'qux', 99.9);

named collection 사용하기:

SELECT * FROM arrowFlight(named_collection_name);

더 알아보기 (Learn more)