DROP TABLE default.poc_pg_persondistinctid;

CREATE TABLE default.poc_pg_persondistinctid
(
    id UInt32,
    distinct_id String,
    version UInt64,
    person_id UInt32,
    team_id UInt32
)
ENGINE = PostgreSQL('db:5432', 'posthog', 'posthog_persondistinctid', 'posthog', 'posthog');

SELECT * FROM poc_pg_persondistinctid LIMIT 10;