SQL/kudu (3) 썸네일형 리스트형 [kudu] query(insert/upsert/update/delete), coding(python, pyspark) [query] INSERT INTO my_first_table VALUES (1, "john"), (2, "jane"), (3, "jim"); UPSERT INTO my_first_table VALUES (99, "zoe"); UPDATE my_first_table SET name="bob" where age > 10; DELETE FROM my_first_table WHERE id < 3; [python] import kudu client = kudu.Client("myhost.com:port") tableName = "impala::tmp.table_name" kuduTable = client.table(tableName) session = client.new_session() op = kuduTab.. [kudu] column add/change 칼럼명 변경 alter table table_name change old_col new_col new_type 칼럼 추가 alter table table_name add columns (col1 type1, col2 type2) [kudu] create table CREATE TABLE my_first_table ( id BIGINT, name STRING, PRIMARY KEY(id) ) PARTITION BY HASH PARTITIONS 6 STORED AS KUDU TBLPROPERTIES ('kudu.master_addresses' = 'host_name') 이전 1 다음