Copy-paste examples of loading data with SQL
1 2
LOAD DATA INTO example.product FROM FILE PATHS 'kifs://data/products.csv'
LOAD DATA INTO example.product FROM FILE PATHS 'kifs://data/products.csv', 'kifs://data/products.kh.csv'
1 2 3
LOAD DATA INTO example.product FROM FILE PATHS 'products.csv' WITH OPTIONS (DATA SOURCE = 'product_ds')
LOAD DATA INTO example.orders FORMAT JSON WITH OPTIONS (DATA SOURCE = 'kafka_ds', SUBSCRIBE = TRUE)
LOAD INTO example.employee_dept2 FROM REMOTE QUERY 'SELECT * FROM example.employee WHERE dept_id = 2' WITH OPTIONS (DATA SOURCE = 'example.jdbc_ds')
LOAD DATA INTO example.product FROM FILE PATHS 'kifs://data/products.nh.csv'
LOAD DATA INTO example.product FROM FILE PATHS 'kifs://data/products.nh.dat' FORMAT TEXT
LOAD DATA INTO example.product FROM FILE PATHS 'kifs://data/products.nh.csv' FORMAT TEXT (INCLUDES HEADER = FALSE)
LOAD DATA INTO example.product_name_stock FROM FILE PATHS 'kifs://data/products.title-case.csv' WITH OPTIONS (FIELDS MAPPED BY NAME(ID, Name, Stock))
LOAD DATA INTO example.product_name_stock FROM FILE PATHS 'kifs://data/products.title-case.csv' WITH OPTIONS (FIELDS IGNORED BY POSITION(2, 4))
1 2 3 4 5 6 7 8 9 10 11
LOAD DATA INTO example.product FROM FILE PATHS 'kifs://data/products.ssv' FORMAT TEXT ( COMMENT = '--', DELIMITER = ';', ESCAPE = '`', INCLUDES HEADER = TRUE, NULL = '<null>', QUOTE = '''' )
LOAD DATA INTO example.product FROM FILE PATHS 'kifs://data/products.json'
LOAD DATA INTO example.events FROM FILE PATHS 'kifs://data/events.json'
LOAD DATA INTO example.product FROM FILE PATHS 'kifs://data/products.dat' FORMAT JSON
LOAD DATA INTO example.product_name_stock FROM FILE PATHS 'kifs://data/products.json' WITH OPTIONS (FIELDS MAPPED BY NAME(ID, Name, Stock))
LOAD DATA INTO example.product_name_stock FROM FILE PATHS 'kifs://data/products.json' WITH OPTIONS (FIELDS IGNORED BY NAME(Category, Description))
LOAD DATA INTO example.ext_employee FROM FILE PATHS 'kifs://data/employee.parquet'
CREATE EXTERNAL TABLE example.ext_employee FILE PATHS 'kifs://data/employee.dat' FORMAT PARQUET
LOAD DATA INTO example.product_name_stock FROM FILE PATHS 'kifs://data/products.parquet' WITH OPTIONS (FIELDS MAPPED BY NAME(ID, Name, Stock))
LOAD DATA INTO example.product_name_stock FROM FILE PATHS 'kifs://data/products.parquet' WITH OPTIONS (FIELDS IGNORED BY NAME(Category, Description))
LOAD DATA INTO example.events FROM FILE PATHS 'kifs://data/events.shp'
LOAD DATA INTO example.events FROM FILE PATHS 'kifs://data/events.shp' FORMAT SHAPEFILE
LOAD DATA INTO example.events FROM FILE PATHS 'kifs://data/events.shp' WITH OPTIONS (FIELDS MAPPED BY NAME(ID, kiGeometry))
LOAD DATA INTO example.events FROM FILE PATHS 'kifs://data/events.shp' WITH OPTIONS (FIELDS IGNORED BY NAME(type))
LOAD INTO example.employee FROM FILE PATHS 'kifs://data/employee.parquet' WITH OPTIONS (PRIMARY KEY = (id))
1 2 3 4 5 6 7
LOAD INTO example.employee FROM FILE PATHS 'kifs://data/employee.csv' WITH OPTIONS ( PRIMARY KEY = (id, dept_id), SHARD KEY = (id) )
CREATE EXTERNAL TABLE example.ext_product FILE PATHS 'products.csv' WITH OPTIONS ( DATA SOURCE = 'product_ds', REFRESH ON START = TRUE )
1 2 3 4 5 6 7 8
CREATE EXTERNAL TABLE example.ext_product FILE PATHS 'products.csv' WITH OPTIONS ( DATA SOURCE = 'product_ds', SUBSCRIBE = TRUE, POLL_INTERVAL = '60' )
CREATE EXTERNAL TABLE example.ext_employee_dept2 REMOTE QUERY 'SELECT * FROM example.ext_employee WHERE dept_id = 2' WITH OPTIONS ( DATA SOURCE = 'example.jdbc_ds', REFRESH ON START = TRUE )