Tantor PipelineDB
Release/1.2
Release/1.3
Release/1.2
Introduction
Overview
What Tantor PipelineDB is
What Tantor PipelineDB is not
Quick start
Analysis of air traffic data
Creating an external table
Creating a view for data aggregation
Loading data and executing queries
Tantor PipelineDB installation
PostgreSQL installation procedure
Downloading the installer
Tantor PipelineDB installation
Parameters:
Example of use:
Creating Tantor PipelineDB extension
Starting PostgreSQL
Configuration
Removing Tantor PipelineDB
Continuous Views
Creating Continuous Views
Dropping Continuous Views
Truncating Continuous Views
Viewing Continuous Views
Data Retrieval
Time-to-Live (TTL) Expiration
Modifying TTLs
Activation and Deactivation
Partitioning
Alternative Access Methods
Examples
Continuous Transforms
Creating Continuous Transforms
Dropping Continuous Transforms
Viewing Continuous Transforms
Continuous Transform Output Streams
Built-in Transform Output Functions
Creating Your Own Output Function
Streams
Writing To Streams
INSERT
Prepared INSERT
COPY
Other Clients
Output Streams
Output Streams on Sliding Windows
Delta Streams
stream_targets
Arrival Ordering
Event Expiration
Built-in Functionality
General
Aggregates
Tantor PipelineDB-specific Types
Tantor PipelineDB-specific Functions
Bloom Filter Functions
Top-K Functions
Frequency Functions
HyperLogLog Functions
Distribution Functions
Miscellaneous Functions
Operational Functions
System Views
Continuous Aggregates
Bloom Filter Aggregates
Frequency Tracking Aggregates
Top-K Aggregates
HyperLogLog Aggregates
Distribution Aggregates
Miscellaneous Aggregates
Combine
General Aggregates
Statistical Aggregates
Ordered-set Aggregates
Hypothetical-set Aggregates
Unsupported Aggregates
Clients
Python
Ruby
Java
Probabilistic Data Structures & Algorithms
Bloom Filter
Count-Min Sketch
Top-K
HyperLogLog
T-Digest
Sliding Windows
Examples
Sliding Aggregates
Temporal Invalidation
step_factor
Continuous JOINs
Stream-table JOINs
Supported Join Types
Examples
Stream-stream JOINs
Backups
Exporting Specific Continuous Views
Restoring Continuous Views
Replication
Streaming Replication
High Availability
Statistics
pipelinedb.proc_stats
pipelinedb.query_stats
pipelinedb.stream_stats
pipelinedb.db_stats
Configuration
Release notes
1.3.4 (2025-02-20)
1.3.3 (2024-12-24)
1.3.2 (2024-12-05)
1.3.1 (2024-11-20)
1.3.0 (2024-11-12)
1.0.0-13 (2019-02-05)
Tantor PipelineDB
Index
Index
Symbols
|
A
|
B
|
C
|
D
|
E
|
F
|
H
|
J
|
K
|
M
|
P
|
R
|
S
|
T
|
V
|
X
|
Y
Symbols
<aggregate_name> (DISTINCT expression)
A
array_agg ( expression )
avg ( expression )
B
bit_and ( expression )
bit_or ( expression )
bloom_add ( bloom, expression )
bloom_agg ( expression )
( expression , p , n )
bloom_cardinality ( bloom )
bloom_contains ( bloom, expression )
bloom_intersection ( bloom, bloom, ... )
bloom_intersection_agg ( bloom filter )
bloom_union ( bloom, bloom, ... )
bloom_union_agg ( bloom filter )
bool_and ( expression )
bool_or ( expression )
bucket_agg ( expression , bucket_id )
( expression , bucket_id , timestamp )
bucket_cardinalities ( bucket_agg )
bucket_cardinality ( bucket_agg, bucket_id )
bucket_ids ( bucket_agg )
C
COLLATE collation
column_name
combine ( aggregate column )
corr ( y, x )
count ( * )
( DISTINCT expression)
( expression )
covar_pop ( y, x )
covar_samp ( y, x )
cume_dist ( arguments )
D
data_type
date_round ( timestamp, resolution )
day ( timestamp )
dense_rank ( arguments )
dist_add ( tdigest, expression, weight )
dist_agg ( expression )
( expression, compression )
dist_cdf ( tdigest, expression )
dist_quantile ( tdigest, float )
E
every ( expression )
exact_count_distinct ( expression )
F
first_values ( n ) WITHIN GROUP (ORDER BY sort_expression)
freq ( cmsketch, expression )
freq_add ( cmsketch, expression, weight )
freq_agg ( expression )
( expression, epsilon, p )
freq_merge_agg ( count-min sketch )
freq_norm ( cmsketch, expression )
freq_total ( cmsketch )
H
hll_add ( hyperloglog, expression )
hll_agg ( expression )
( expression, p )
hll_cardinality ( hyperloglog )
hll_union ( hyperloglog, hyperloglog, ... )
hll_union_agg ( hyperloglog )
hour ( timestamp )
J
json_agg ( expression )
json_object_agg ( key, value )
jsonb_agg ( expression )
jsonb_object_agg ( key, value )
K
keyed_max ( key, value )
keyed_min ( key, value )
M
max ( expression )
min ( expression )
minute ( timestamp )
mode ( )
month ( timestamp )
P
percent_rank ( arguments )
percentile_cont ( array of fractions )
( fraction )
percentile_disc ( arguments )
pipelinedb.activate ( name )
pipelinedb.batch_mem
pipelinedb.batch_size
pipelinedb.combine_table( continuous view name, table )
pipelinedb.combiner_work_mem
pipelinedb.commit_interval
pipelinedb.continuous_queries_enabled
pipelinedb.deactivate ( name )
pipelinedb.fillfactor
pipelinedb.get_transforms ( )
pipelinedb.get_views ( )
pipelinedb.index_fillfactor
pipelinedb.ipc_hwm
pipelinedb.log_partitions
pipelinedb.matrels_writable
pipelinedb.max_wait
pipelinedb.num_combiners
pipelinedb.num_queues
pipelinedb.num_reapers
pipelinedb.num_workers
pipelinedb.queue_mem
pipelinedb.sliding_window_step_factor
pipelinedb.stream_insert_level
pipelinedb.stream_targets
pipelinedb.truncate_continuous_view ( name )
pipelinedb.ttl_expiration_batch_size
pipelinedb.ttl_expiration_threshold
pipelinedb.version ( )
R
rank ( arguments )
regr_avgx ( y, x )
regr_avgy ( y, x )
regr_count ( y, x )
regr_intercept ( y, x )
regr_r2 ( y, x )
regr_slope ( y, x )
regr_sxx ( y, x )
regr_sxy ( y, x )
regr_syy ( y, x )
S
second ( timestamp )
set_agg ( expression )
set_cardinality ( array )
stddev ( expression )
stddev_pop ( expression )
step_factor
stream_name
string_agg ( expression, delimiter )
sum ( expression )
T
topk ( topk )
topk_agg ( expression , k )
(expression, k, weight )
topk_freqs ( topk )
topk_increment ( topk, expression )
( topk, expression, weight )
topk_merge_agg ( topk )
topk_values ( topk )
V
var_pop ( expression )
variance ( expression )
X
xmlagg ( xml )
Y
year ( timestamp )
Commercial use is possible only with the
written
permission of Tantor Labs LLC