시작하기 전에

이 예에서는 2022년 1월 노란색 택시에 대한 공개적으로 사용 가능한 뉴욕 택시 운행 기록 데이터 ' {: external} '을 사용했습니다. 이 예제를 따르려면 데이터가 액세스 가능한 S3 버킷에 있고 테이블이 watsonx.data Hive Metastore 서버(HMS)의 Apache Iceberg 테이블로 로드되었는지 확인합니다.

1. NPSaaS 데이터베이스에 연결합니다.

MYLAKE.TAXIDATA(ADMIN)=> \c localdb

이제 localdb 데이터베이스에 연결되었습니다.

2. 데이터 레이크 database.schema.table 교차 데이터베이스 선택으로 CTAS 쿼리를 실행합니다.

예:

LOCALDB.ADMIN(ADMIN)=> CREATE TABLE YELLOW_TAXI_JANUARY_2022_LOADED AS SELECT * FROM MYLAKE.TAXIDATA.YELLOW_TAXI_JANUARY_2022;
INSERT 0 2463931