hongbo-miao/hongbomiao.com

View on GitHub
data-processing/flink/applications/stream-tweets/migrations/000002_create_tweet_table.up.sql

Summary

Maintainability
Test Coverage
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');