pipelinedb

pipelinedb copied to clipboard

When creating a stream, the arrival_timestamp is automatically created regardless of the user defined schema. While that is fine, the format of this column seems to be locked to a...

matzhaugenOI

I'm using the docker image provided at https://hub.docker.com/r/pipelinedb/pipelinedb-postgresql-11 tag 1.0.0-12 I don't even created any stream yet on this database, just creating tables, inserting, updating data from blockchain project As...

Speedkore

This command is expected to not throw an error when the foreign table exists, but currently it prints an error related to pipelinedb: ``` CREATE FOREIGN TABLE IF NOT EXISTS...

hedayat

DROP DATABASE command fails due to background workers

3

Our testing environment attempts to drop databases before recreating them. But the `DROP DATABASE` command fails with: ``` ERROR: database "testdb" is being accessed by other users DETAIL: There are...

andrew-blake

Batched transforms

2

For transforms that do things like write to external datastores, it's going to be useful to process tuples in batches. In addition to batch size, we'll also need to support...

derekjn

Not able to get version of pipelineDB

1

I can get the version of the pipeline DB. I am getting output as below. pipeline=# SELECT pipeline_version(); pipeline_version -------------------------------------------------------------------------------------- PipelineDB at revision on x86_64-pc-linux-gnu, compiled by gcc (GCC) 7.1.0,...

RajeevRastogi

**SQL:** ```sql SELECT f_ds, f_hour, combine(uv) OVER(PARTITION BY f_ds ORDER BY f_hour) AS uv FROM dw_utrack.rt_view_track_overview_utrack WHERE f_ds = '2019-02-25' ; ``` **Error message:** `ERROR: invalid input syntax for integer:...

sunmatus

CREATE FOREIGN TABLE wiki_stream ( hour timestamp, project text, title text, view_count bigint, size bigint) SERVER pipelinedb; CREATE VIEW wiki_stats WITH (action=materialize) AS SELECT hour, project, count(*) AS total_pages, sum(view_count)...

zfz1989

derekjn

Currently we use our own function to choose the next append plan in order to filter out irrelevant partitions. The benefit of this approach is that it’s very simple and...

derekjn