# 테이블 생성
CREATE TABLE mytable (
  `time` TIMESTAMP(3),
  `host` STRING,
  `method` STRING,
  `path` STRING,
  `version` STRING,
  `code` STRING,
  WATERMARK FOR time AS time - INTERVAL '5' SECOND
)
WITH (
  'connector' = 'kinesis',
  'stream' = 'test',
  'aws.region' = 'ap-northeast-2',
  'scan.stream.initpos' = 'TRIM_HORIZON', # LATEST
  'format' = 'json'
);