Loading Data

LOAD DATA INTO example.product
FROM FILE PATHS 'kifs://data/products.csv'

LOAD DATA INTO example.product
FROM FILE PATHS 'products.csv'
WITH OPTIONS (DATA SOURCE = 'example.product_ds')

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.csv'

LOAD DATA INTO example.product
FROM FILE PATHS 'kifs://data/products.json'

LOAD DATA INTO example.ext_employee
FROM FILE PATHS 'kifs://data/employee.parquet'

LOAD DATA INTO example.events
FROM FILE PATHS 'shapefile/events.shp'
WITH OPTIONS (DATA SOURCE = 'example.events_ds')

LOAD DATA INTO example.orders
FORMAT AVRO
WITH OPTIONS
(
	DATA SOURCE = 'kafka_ds',
	SUBSCRIBE = TRUE
)

LOAD INTO example.employee
FROM FILE PATHS 'kifs://data/employee.parquet'
WITH OPTIONS (PRIMARY KEY = (id))

LOAD INTO example.employee_local
FROM REMOTE QUERY 'SELECT * FROM example.employee'
WITH OPTIONS
(
	DATA SOURCE = 'example.jdbc_ds',
	REMOTE_QUERY_PARTITION_COLUMN = 'id'
)

LOAD INTO example.employee
FROM FILE PATHS 'kifs://data/employee.csv'
WITH OPTIONS
(
	COLUMN FORMATS = '
	{
		"hire_date": {"date": "YYYY-MM-DD"}
	}'
)

CREATE EXTERNAL TABLE example.ext_product
FILE PATHS 'products.csv'
WITH OPTIONS (DATA SOURCE = 'example.product_ds', REFRESH ON START = TRUE)