data-processing/flink/applications/stream-tweets/migrations/000002_create_tweet_table.up.sql
create table if not exists tweet
(
timestamp timestamp without time zone not null,
id text not null,
twitter_user_id text not null,
text text not null,
lang text not null
);
select create_hypertable('tweet', 'timestamp');