CREATE TABLE csv_adfeature (
  aid VARCHAR NOT NULL,
  advertiser_id VARCHAR NOT NULL,
  campaign_id VARCHAR NOT NULL,
  creative_id VARCHAR NOT NULL,
  creative_size VARCHAR NOT NULL,
  category_id VARCHAR NOT NULL,
  product_id VARCHAR NOT NULL,
  product_type VARCHAR NOT NULL,
  PRIMARY KEY(aid)
) WITH (
  type = 'postgres',
  connector.version = '9.4',
  username = 'postgres',
  password = '123456',
  tablename = 'adFeature',
  dburl = 'jdbc:postgresql://localhost:5432/postgres'
);

// create probe side table
create table train (
  aid VARCHAR NOT NULL,
  uid VARCHAR NOT NULL,
  label VARCHAR NOT NULL
) with (
  type = 'csv',
  firstLineAsHeader='true',
  path = 'file:///bigdata/datasets/train10.csv'
);


// temporal table join
SELECT
p.aid, p.uid, b.advertiser_id
FROM train AS p
INNER JOIN
adfeature FOR SYSTEM_TIME AS OF PROCTIME() AS b
ON p.aid = b.aid;